kafka-docker-playground

(★ 787)

🐳✨ Fully automated Apache Kafka® and Confluent Docker based examples // 👷‍♂️ Easily build examples or reproduction models

File Explorer

Download Latest Version (.zip)

Showing a partial file list — download the zip above to see everything.

- - decrypt_secret.sh
- - badges.yml
  - ci.yml
  - update-changelogs.yml
  - update-readme.yml
- release-notes.yml
- - docker-compose.plaintext.backup-and-restore-assuming-iam-role-with-custom-aws-credential-provider.yml
  - docker-compose.plaintext.proxy-basic-auth.yml
  - docker-compose.plaintext.proxy.with-assuming-iam-role.yml
  - docker-compose.plaintext.proxy.yml
  - docker-compose.plaintext.repro-000001-stackoverflowerror-with-s3-sink-connector.yml
  - docker-compose.plaintext.with-assuming-iam-role-config.yml
  - docker-compose.plaintext.with-assuming-iam-role.yml
  - docker-compose.plaintext.yml
  - README.md
  - s3-sink-repro-000001-stackoverflowerror-with-s3-sink-connector.sh
  - stop.sh
- - debezium-sqlserver-source-repro-pipeline-example.sh
  - docker-compose.plaintext.repro-pipeline-example.yml
  - docker-compose.plaintext.ssl.yml
  - docker-compose.plaintext.standalone-worker.yml
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - .gitignore
  - docker-compose.plaintext.repro-000002-deserialization-error.yml
  - docker-compose.plaintext.repro-000003-insertfield-smt-dataexception-only-struct-objects-supported.yml
  - docker-compose.plaintext.yml
  - filestream-sink-repro-000002-deserialization-error.sh
  - filestream-sink-repro-000003-insertfield-smt-dataexception-only-struct-objects-supported.sh
  - README.md
  - stop.sh
- - .gitignore
  - docker-compose.plaintext.repro-000004-insertfield-smt-dataexception-only-struct-objects-supported.yml
  - docker-compose.plaintext.yml
  - filestream-source-repro-000004-insertfield-smt-dataexception-only-struct-objects-supported.sh
  - README.md
  - stop.sh
- - docker-compose.plaintext.mtls.yml
  - docker-compose.plaintext.repro-000005-insertfield-smt:-adding-topic-offset-and-partition-not-working.yml
  - docker-compose.plaintext.ssl.yml
  - docker-compose.plaintext.yml
  - mysql-repro-000005-insertfield-smt:-adding-topic-offset-and-partition-not-working.sh
  - README.md
  - stop.sh
- - .gitignore
  - config-org.apache.kafka.connect.file.FileStreamSinkConnector.json
  - config-org.apache.kafka.connect.file.FileStreamSinkConnector.txt
  - data_audit_cluster.template
  - docker-compose.yml
  - README.md
  - start.sh
  - stop.sh
- - CCloud2.2.csproj
  - CCloud3.1.csproj
  - curl-cacert.txt
  - Dockerfile
  - Dockerfile-Minikube
  - letsencrypt-cacert.txt
  - librdkafka.config.template
  - pod.yml
  - pod_initContainers.yml
  - Program.cs
  - README.md
  - start.sh
  - stop.sh
- - confluent.repo
  - consumer.go
  - Dockerfile
  - go.mod
  - go.sum
  - librdkafka.config.template
  - producer.go
  - README.md
  - start.sh
  - stop.sh
- - .gitignore
  - 1.jpg
  - 2.jpg
  - consumer-template.js
  - Dockerfile
  - producer-template.js
  - README.md
  - start.sh
  - stop.sh
- - .gitignore
  - ccloud_lib.py
  - consumer.py
  - consumer_ccsr.py
  - Dockerfile
  - librdkafka.config.template
  - producer.py
  - producer_ccsr.py
  - README.md
  - requirements.txt
  - start.sh
  - stop.sh
- - acl.sync.all.json
  - consumer.offset.sync.all.json
  - destination.config
  - README.md
  - source.config
- - .gitignore
  - confluent-platform-template.yaml
  - creds-client-kafka-sasl-user-template.txt
  - creds-control-center-users.txt
  - creds-schemaRegistry-user-template.txt
  - README.md
  - start.sh
  - stop.sh
- - .gitignore
  - docker-compose-connect-onprem-to-cloud.yml
  - docker-compose.mqtt-source.yml
  - docker-compose.redshift.yml
  - docker-compose.servicenow-source.yml
  - mqtt-source.sh
  - redshift.sh
  - replicator-onprem-to-cloud.sh
  - servicenow-source.sh
  - stop.sh
- - cloudwatch-metrics-sink.sh
  - config-io.confluent.connect.aws.cloudwatch.metrics.AwsCloudWatchMetricsSinkConnector.json
  - config-io.confluent.connect.aws.cloudwatch.metrics.AwsCloudWatchMetricsSinkConnector.txt
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - .gitignore
  - custom-s3-sink.sh
  - README.md
  - stop.sh
- - .gitignore
  - custom-iceberg-sink.sh
  - docker-compose.yml
  - ngrok.yml
  - README.md
  - stop.sh
- - .gitignore
  - data.template
  - docker-compose.no-replicator-monitoring.yml
  - docker-compose.yml
  - README.md
  - start.sh
  - stop.sh
- - config-ActiveMQSource.json
  - config-ActiveMQSource.txt
  - docker-compose.yml
  - fully-managed-active-mq-source.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - .gitignore
  - config-CloudWatchLogsSource.json
  - config-CloudWatchLogsSource.txt
  - fully-managed-cloudwatch.sh
  - README.md
  - stop.sh
- - config-CloudWatchMetricsSink.json
  - config-CloudWatchMetricsSink.txt
  - fully-managed-cloudwatch-metrics-sink.sh
  - README.md
  - stop.sh
- - config-DynamoDbCdcSource.json
  - config-DynamoDbCdcSource.txt
  - config-DynamoDbSink.json
  - config-DynamoDbSink.txt
  - fully-managed-dynamodb-cdc-source.sh
  - README.md
  - stop.sh
- - config-DynamoDbSink.json
  - config-DynamoDbSink.txt
  - fully-managed-dynamodb-sink.sh
  - README.md
  - stop.sh
- - config-KinesisSource.json
  - config-KinesisSource.txt
  - fully-managed-kinesis-source.sh
  - README.md
  - stop.sh
- - config-LambdaSink.json
  - config-LambdaSink.txt
  - fully-managed-lambda-sink.sh
  - README.md
  - stop.sh
- - config-RedshiftSink.json
  - config-RedshiftSink.txt
  - fully-managed-redshift-sink.sh
  - README.md
  - stop.sh
- - .gitignore
  - config-S3_SINK.json
  - config-S3_SINK.txt
  - fully-managed-s3-sink-confluent-cloud-provider-integration.sh
  - fully-managed-s3-sink.sh
  - README.md
  - stop.sh
- - .gitignore
  - config-S3Source.json
  - config-S3Source.txt
  - fully-managed-s3-source.sh
  - generalized.quickstart.json
  - README.md
  - stop.sh
- - config-SqsSource.json
  - config-SqsSource.txt
  - fully-managed-sqs-source.sh
  - README.md
  - send-message-batch.json
  - stop.sh
- - config-AzureBlobSink.json
  - config-AzureBlobSink.txt
  - fully-managed-azure-blob-storage-sink.sh
  - README.md
  - stop.sh
- - config-AzureBlobSource.json
  - config-AzureBlobSource.txt
  - fully-managed-azure-blob-storage-source.sh
  - generalized.quickstart.json
  - README.md
  - stop.sh
- - config-AzureCognitiveSearchSink.json
  - config-AzureCognitiveSearchSink.txt
  - fully-managed-azure-cognitive-search-sink.sh
  - README.md
  - stop.sh
- - config-CosmosDbSink.json
  - config-CosmosDbSink.txt
  - docker-compose.yml
  - fully-managed-azure-cosmosdb-sink.sh
  - README.md
  - stop.sh
- - config-CosmosDbSource.json
  - config-CosmosDbSource.txt
  - docker-compose.yml
  - fully-managed-azure-cosmosdb-source.sh
  - README.md
  - stop.sh
- - config-CosmosDbSinkV2.json
  - config-CosmosDbSinkV2.txt
  - docker-compose.yml
  - fully-managed-azure-cosmosdb-v2-sink.sh
  - README.md
  - stop.sh
- - config-CosmosDbSourceV2.json
  - config-CosmosDbSourceV2.txt
  - docker-compose.yml
  - fully-managed-azure-cosmosdb-v2-source.sh
  - README.md
  - stop.sh
- - config-AzureDataLakeGen2Sink.json
  - config-AzureDataLakeGen2Sink.txt
  - fully-managed-azure-data-lake-storage-gen2-sink.sh
  - README.md
  - stop.sh
- - .gitignore
  - config-AzureEventHubsSource.json
  - config-AzureEventHubsSource.txt
  - docker-compose.yml
  - fully-managed-azure-event-hubs.sh
  - README.md
  - stop.sh
- - .gitignore
  - config-AzureFunctionsSink.json
  - config-AzureFunctionsSink.txt
  - fully-managed-azure-functions-sink.sh
  - README.md
  - stop.sh
- - config-AzureLogAnalyticsSink.json
  - config-AzureLogAnalyticsSink.txt
  - fully-managed-azure-log-analytics-sink.sh
  - README.md
  - stop.sh
- - config-AzureLogAnalyticsSinkV2.json
  - config-AzureLogAnalyticsSinkV2.txt
  - fully-managed-azure-log-analytics-v2-sink.sh
  - README.md
  - stop.sh
- - .gitignore
  - config-AzureServiceBusSource.json
  - config-AzureServiceBusSource.txt
  - docker-compose.yml
  - fully-managed-azure-service-bus-source.sh
  - README.md
  - stop.sh
- - config-AzureSqlDwSink.json
  - config-AzureSqlDwSink.txt
  - fully-managed-azure-synapse-analytics-sink.sh
  - README.md
  - stop.sh
- - .gitignore
  - config-OracleCdcSource.json
  - config-OracleCdcSource.txt
  - docker-compose.yml
  - fully-managed-cdc-oracle19-cdb-table.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - .gitignore
  - config-OracleXStreamSource.json
  - config-OracleXStreamSource.txt
  - docker-compose.ssl.yml
  - docker-compose.yml
  - fully-managed-cdc-xstream-oracle19-blocking-snapshot.sh
  - fully-managed-cdc-xstream-oracle19-ssl-wallet.sh
  - fully-managed-cdc-xstream-oracle19.sh
  - ngrok.ssl.yml
  - ngrok.yml
  - orclcdc_readiness.sql
  - README.md
  - Screenshot1.png
  - stop.sh
- - config-ClickHouseSink.json
  - config-ClickHouseSink.txt
  - fully-managed-clickhouse-sink.sh
  - README.md
  - stop.sh
- - config-CouchbaseSink.json
  - config-CouchbaseSink.txt
  - fully-managed-couchbase-sink.sh
  - README.md
  - screenshot1.png
  - screenshot2.png
  - screenshot3.png
  - screenshot4.png
  - stop.sh
- - config-CouchbaseSource.json
  - config-CouchbaseSource.txt
  - fully-managed-couchbase-source.sh
  - README.md
  - screenshot1.png
  - screenshot2.png
  - screenshot3.png
  - screenshot4.png
  - stop.sh
- - .gitignore
  - docker-compose.noauth.yml
  - fm-custom-smt-http-v2-sink.sh
  - kafka-connect-insert-uuid
  - README.md
  - stop.sh
- - .gitignore
  - config-MySqlSink.json
  - config-MySqlSink.txt
  - docker-compose.yml
  - fm-custom-smt-mysql-sink.sh
  - kafka-connect-insert-uuid
  - README.md
  - stop.sh
- - config-DatabricksDeltaLakeSink.json
  - config-DatabricksDeltaLakeSink.txt
  - config-DatagenSource.json
  - config-DatagenSource.txt
  - fully-managed-databricks-delta-lake-sink.sh
  - README.md
  - screenshot1.jpg
  - stop.sh
- - config-DatadogMetricsSink.json
  - config-DatadogMetricsSink.txt
  - fully-managed-datadog-metrics-sink.sh
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - stop.sh
- - config-DatagenSource.json
  - config-DatagenSource.txt
  - fully-managed-datagen-source.sh
  - README.md
  - stop.sh
- - config-SpannerCdcSource.json
  - config-SpannerCdcSource.txt
  - fully-managed-debezium-cdc-gcp-spanner-source.sh
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - Screenshot3.png
  - Screenshot4.png
  - stop.sh
- - .gitignore
  - config-MariaDbCdcSource.json
  - config-MariaDbCdcSource.txt
  - docker-compose.yml
  - fully-managed-debezium-mariadb.sh
  - mysql-init.sql
  - mysql.cnf
  - ngrok.yml
  - README.md
  - stop.sh
- - .gitignore
  - config-MongoDbCdcSource.json
  - config-MongoDbCdcSource.txt
  - docker-compose-ssl.yml
  - docker-compose.yml
  - fully-managed-debezium-mongodb-source-ssl.sh
  - fully-managed-debezium-mongodb-source.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - .gitignore
  - config-MySqlCdcSourceV2.json
  - config-MySqlCdcSourceV2.txt
  - docker-compose.yml
  - fully-managed-debezium-v2-mysql.sh
  - mysql-init.sql
  - mysql.cnf
  - ngrok.yml
  - README.md
  - stop.sh
- - .gitignore
  - config-PostgresCdcSourceV2.json
  - config-PostgresCdcSourceV2.txt
  - docker-compose.yml
  - fully-managed-v2-postgres.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - config-SqlServerCdcSourceV2.json
  - config-SqlServerCdcSourceV2.txt
  - docker-compose-ssl.yml
  - docker-compose.yml
  - fully-managed-debezium-v2-sqlserver-source-ssl.sh
  - fully-managed-debezium-v2-sqlserver-source.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - .gitignore
  - config-ElasticsearchSink.json
  - config-ElasticsearchSink.txt
  - docker-compose.yml
  - fully-managed-elasticsearch-sink.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - config-ElasticsearchSinkV2.json
  - config-ElasticsearchSinkV2.txt
  - docker-compose.yml
  - fully-managed-elasticsearch-v2-sink.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - .gitignore
  - config-BigQueryStorageSink.json
  - config-BigQueryStorageSink.txt
  - fully-managed-gcp-bigquery-sink-v2.sh
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - Screenshot3.png
  - Screenshot4.png
  - stop.sh
- - config-BigTableSink.json
  - config-BigTableSink.txt
  - fully-managed-gcp-bigtable-sink.sh
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - Screenshot3.png
  - Screenshot4.png
  - Screenshot5.png
  - stop.sh
- - config-GoogleCloudFunctionsGen2Sink.json
  - config-GoogleCloudFunctionsGen2Sink.txt
  - fully-managed-google-cloud-functions-gen2-sink.sh
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - stop.sh
- - config-FirestoreSink.json
  - config-FirestoreSink.txt
  - fully-managed-gcp-firestore-sink.sh
  - README.md
  - stop.sh
- - config-GcsSink.json
  - config-GcsSink.txt
  - fully-managed-gcs-sink.sh
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - Screenshot3.png
  - Screenshot4.png
  - stop.sh
- - config-GcsSource.json
  - config-GcsSource.txt
  - fully-managed-gcs-source.sh
  - generalized.quickstart.json
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - Screenshot3.png
  - Screenshot4.png
  - stop.sh
- - config-PubSubSource.json
  - config-PubSubSource.txt
  - fully-managed-gcp-pubsub-source.sh
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - Screenshot3.png
  - Screenshot4.png
  - stop.sh
- - config-SpannerSink.json
  - config-SpannerSink.txt
  - fully-managed-gcp-spanner-sink.sh
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - Screenshot3.png
  - Screenshot4.png
  - stop.sh
- - config-GithubSource.json
  - config-GithubSource.txt
  - fully-managed-github-source.sh
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - Screenshot3.png
  - Screenshot4.png
  - stop.sh
- - .gitignore
  - config-HttpSink.json
  - config-HttpSink.txt
  - docker-compose.basic-auth.yml
  - docker-compose.mtls-auth.yml
  - docker-compose.noauth.yml
  - docker-compose.oauth2.yml
  - fully-managed-http-basic-auth.sh
  - fully-managed-http-sink-mtls-auth.sh
  - fully-managed-http-sink-oauth2.sh
  - fully-managed-http-sink.sh
  - ngrok-basic-auth.yml
  - ngrok-mtls-auth.yml
  - ngrok.yml
  - README.md
  - stop.sh
- - .gitignore
  - config-HttpSource.json
  - config-HttpSource.txt
  - docker-compose.oauth2.yml
  - docker-compose.yml
  - fully-managed-http-source-chaining-offset.sh
  - fully-managed-http-source-cursor-pagination.sh
  - fully-managed-http-source-oauth2.sh
  - fully-managed-http-source-simple-incrementing.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - config-HttpSinkV2.json
  - config-HttpSinkV2.txt
  - docker-compose.basic-auth.yml
  - docker-compose.mtls-auth.yml
  - docker-compose.noauth.yml
  - docker-compose.oauth2.yml
  - fully-managed-http-v2-basic-auth.sh
  - fully-managed-http-v2-sink-mtls-auth.sh
  - fully-managed-http-v2-sink-oauth2.sh
  - fully-managed-http-v2-sink.sh
  - ngrok-basic-auth.yml
  - ngrok-mtls-auth.yml
  - ngrok.yml
  - README.md
  - stop.sh
- - config-HttpSourceV2.json
  - config-HttpSourceV2.txt
  - docker-compose.oauth2.yml
  - docker-compose.yml
  - fully-managed-http-source-v2-oauth2.sh
  - fully-managed-http-v2-source-chaining-offset.sh
  - fully-managed-http-v2-source-cursor-pagination.sh
  - fully-managed-http-v2-source-simple-incrementing.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - .gitignore
  - config-IbmMqSink.json
  - config-IbmMqSink.txt
  - docker-compose-mtls.yml
  - docker-compose-ssl.yml
  - docker-compose.yml
  - fully-managed-ibm-mq-sink-eos.sh
  - fully-managed-ibm-mq-sink-mtls.sh
  - fully-managed-ibm-mq-sink-ssl.sh
  - fully-managed-ibm-mq-sink.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - .gitignore
  - config-IbmMQSource.json
  - config-IbmMQSource.txt
  - docker-compose-mtls.yml
  - docker-compose-ssl.yml
  - docker-compose.yml
  - fully-managed-ibm-mq-source-eos.sh
  - fully-managed-ibm-mq-source-mtls.sh
  - fully-managed-ibm-mq-source-ssl.sh
  - fully-managed-ibm-mq-source.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - config-InfluxDB2Sink.json
  - config-InfluxDB2Sink.txt
  - docker-compose.yml
  - fully-managed-influxdb2-sink.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - config-InfluxDB2Source.json
  - config-InfluxDB2Source.txt
  - docker-compose.yml
  - fully-managed-influxdb2-source.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - config-InfluxDB3Sink.json
  - config-InfluxDB3Sink.txt
  - docker-compose.yml
  - fully-managed-influxdb3-sink.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - .gitignore
  - config-IbmDb2Source.json
  - config-IbmDb2Source.txt
  - docker-compose.ssl.yml
  - docker-compose.yml
  - fully-managed-ibmdb2-source-ssl.sh
  - fully-managed-ibmdb2-source.sh
  - ngrok.ssl.yml
  - ngrok.yml
  - README.md
  - stop.sh
- - config-MySqlSink.json
  - config-MySqlSink.txt
  - docker-compose.yml
  - fully-managed-mysql-sink.sh
  - mysql-init.sql
  - ngrok.yml
  - README.md
  - stop.sh
- - config-MySqlSource.json
  - config-MySqlSource.txt
  - docker-compose.yml
  - fully-managed-mysql-source-ssl.sh
  - fully-managed-mysql-source.sh
  - mysql-init.sql
  - ngrok.yml
  - README.md
  - stop.sh
- - .gitignore
  - config-OracleDatabaseSink.json
  - docker-compose.yml
  - fully-managed-jdbc-oracle19-sink.sh
  - ngrok.yml
  - README.md
  - Screenshot1.png
  - stop.sh
- - .gitignore
  - config-OracleDatabaseSource.json
  - config-OracleDatabaseSource.txt
  - docker-compose.ssl.yml
  - docker-compose.yml
  - fully-managed-jdbc-oracle19-source-ssl.sh
  - fully-managed-jdbc-oracle19-source.sh
  - ngrok-ssl.yml
  - ngrok.yml
  - README.md
  - stop.sh
- - .gitignore
  - config-PostgresSink.json
  - config-PostgresSink.txt
  - docker-compose-ssl.yml
  - docker-compose.yml
  - fully-managed-jdbc-postgres-sink-ssl.sh
  - fully-managed-jdbc-postgres-sink.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - config-PostgresSource.json
  - config-PostgresSource.txt
  - docker-compose-ssl.yml
  - docker-compose.yml
  - fully-managed-jdbc-postgres-source-ssl.sh
  - fully-managed-jdbc-postgres-source.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - config-MicrosoftSqlServerSink.json
  - config-MicrosoftSqlServerSink.txt
  - docker-compose.yml
  - fully-managed-sqlserver-microsoft-sink.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - config-MicrosoftSqlServerSource.json
  - config-MicrosoftSqlServerSource.txt
  - docker-compose.yml
  - fully-managed-sqlserver-source.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - config-JiraSource.json
  - config-JiraSource.txt
  - fully-managed-jira-source.sh
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - Screenshot3.png
  - stop.sh
- - config-MongoDbAtlasSink.json
  - config-MongoDbAtlasSink.txt
  - fully-managed-mongodb-atlas-sink.sh
  - README.md
  - stop.sh
- - config-MongoDbAtlasSource.json
  - config-MongoDbAtlasSource.txt
  - fully-managed-mongodb-atlas-source.sh
  - README.md
  - stop.sh
- - config-MongoDbAtlasSink.json
  - config-MongoDbAtlasSink.txt
  - docker-compose.yml
  - fully-managed-mongodb-sink.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - config-MongoDbAtlasSource.json
  - config-MongoDbAtlasSource.txt
  - docker-compose.yml
  - fully-managed-mongodb-source.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - .gitignore
  - config-MqttSink.json
  - config-MqttSink.txt
  - docker-compose.mtls.yml
  - docker-compose.yml
  - fully-managed-mqtt-sink-mtls.sh
  - fully-managed-mqtt-sink.sh
  - mosquitto.conf
  - ngrok.yml
  - password
  - README.md
  - stop.sh
- - .gitignore
  - config-MqttSource.json
  - config-MqttSource.txt
  - docker-compose.mtls.yml
  - docker-compose.yml
  - fully-managed-mqtt-source-mtls.sh
  - fully-managed-mqtt-source.sh
  - mosquitto.conf
  - ngrok.yml
  - password
  - README.md
  - stop.sh
- - config-DatagenSource.json
  - config-DatagenSource.txt
  - config-Neo4jSink.json
  - config-Neo4jSink.txt
  - docker-compose.yml
  - fully-managed-neo4j-sink.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - config-OpenSearchSink.json
  - config-OpenSearchSink.txt
  - docker-compose.yml
  - fully-managed-opensearch-sink.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - config-RabbitMQSink.json
  - config-RabbitMQSink.txt
  - docker-compose.ssl.yml
  - docker-compose.yml
  - fully-managed-rabbitmq-sink-ssl.sh
  - fully-managed-rabbitmq-sink.sh
  - ngrok-ssl.yml
  - ngrok.yml
  - README.md
  - stop.sh
- - .gitignore
  - config-RabbitMQSource.json
  - config-RabbitMQSource.txt
  - docker-compose.ssl.yml
  - docker-compose.yml
  - fully-managed-rabbitmq-source-ssl.sh
  - fully-managed-rabbitmq-source.sh
  - ngrok-ssl.yml
  - ngrok.yml
  - README.md
  - stop.sh
- - config-RedisKafkaSink.json
  - config-RedisKafkaSink.txt
  - docker-compose.yml
  - fully-managed-redis-kafka-sink.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - config-RedisKafkaSource.json
  - config-RedisKafkaSource.txt
  - docker-compose.yml
  - fully-managed-redis-kafka-source.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - config-RedisSink.json
  - config-RedisSink.txt
  - docker-compose.yml
  - fully-managed-redis-sink.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - config-SalesforceBulkApiV2Sink.json
  - config-SalesforceBulkApiV2Sink.txt
  - config-SalesforcePushTopicSource.json
  - config-SalesforcePushTopicSource.txt
  - docker-compose.yml
  - fully-managed-salesforce-bulkapi-2-0-sink.sh
  - README.md
  - Screenshot1.png
  - stop.sh
- - config-SalesforceBulkApiV2Source.json
  - config-SalesforceBulkApiV2Source.txt
  - docker-compose.yml
  - fully-managed-salesforce-bulkapi-2-0-source.sh
  - README.md
  - Screenshot1.png
  - stop.sh
- - config-SalesforceBulkApiSource.json
  - config-SalesforceBulkApiSource.txt
  - docker-compose.yml
  - fully-managed-salesforce-bulkapi-source.sh
  - README.md
  - Screenshot1.png
  - stop.sh
- - .gitignore
  - allow-creation-connected-apps.png
  - config-SalesforceCdcSource.json
  - config-SalesforceCdcSource.txt
  - docker-compose.yml
  - fully-managed-salesforce-cdc-source.sh
  - jwt-bearer-authentication1.jpg
  - jwt-bearer-authentication2.jpg
  - jwt-bearer-authentication3.jpg
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - Screenshot3.png
  - Screenshot4.png
  - Screenshot5.png
  - ScreenshotOauthDisabled.jpg
  - stop.sh
- - .gitignore
  - config-SalesforcePlatformEventSink.json
  - config-SalesforcePlatformEventSink.txt
  - config-SalesforcePlatformEventSource.json
  - config-SalesforcePlatformEventSource.txt
  - docker-compose.yml
  - event.apex
  - fully-managed-salesforce-platform-events-sink.sh
  - README.md
  - Screenshot1.png
  - Screenshot10.png
  - Screenshot2.png
  - Screenshot3.png
  - Screenshot4.png
  - Screenshot5.png
  - Screenshot6.png
  - Screenshot7.png
  - Screenshot8.png
  - Screenshot9.png
  - stop.sh
- - config-SalesforcePlatformEventSource.json
  - config-SalesforcePlatformEventSource.txt
  - docker-compose.yml
  - event.apex
  - fully-managed-salesforce-platform-events-source.sh
  - README.md
  - Screenshot1.png
  - Screenshot10.png
  - Screenshot2.png
  - Screenshot3.png
  - Screenshot4.png
  - Screenshot5.png
  - Screenshot6.png
  - Screenshot7.png
  - Screenshot8.png
  - Screenshot9.png
  - stop.sh
- - .gitignore
  - config-SalesforcePushTopicSource.json
  - config-SalesforcePushTopicSource.txt
  - docker-compose.yml
  - fully-managed-salesforce-pushtopic-source.sh
  - MyLeadPushTopics-template.apex
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - Screenshot3.png
  - stop.sh
- - .gitignore
  - config-SalesforcePushTopicSource.json
  - config-SalesforcePushTopicSource.txt
  - config-SalesforceSObjectSink.json
  - config-SalesforceSObjectSink.txt
  - docker-compose.yml
  - fully-managed-salesforce-sobject-sink.sh
  - MyLeadPushTopics-template.apex
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - Screenshot3.png
  - Screenshot4.png
  - stop.sh
- - config-SalesforceSourceV2.json
  - config-SalesforceSourceV2.txt
  - docker-compose.yml
  - fully-managed-salesforce-v2-source.sh
  - README.md
  - Screenshot1.png
  - stop.sh
- - config-ServiceNowSink.json
  - config-ServiceNowSink.txt
  - fully-managed-servicenow-sink.sh
  - README.md
  - Screenshot1.jpg
  - screenshot2.png
  - stop.sh
- - config-ServiceNowSource.json
  - config-ServiceNowSource.txt
  - fully-managed-servicenow-source.sh
  - README.md
  - stop.sh
- - config-ServiceNowSourceV2.json
  - config-ServiceNowSourceV2.txt
  - fully-managed-servicenow-v2-source.sh
  - README.md
  - stop.sh
- - .gitignore
  - config-SftpSink.json
  - config-SftpSink.txt
  - docker-compose.yml
  - fully-managed-sftp-sink.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - .gitignore
  - config-SftpSource.json
  - config-SftpSource.txt
  - docker-compose.yml
  - fully-managed-sftp-source-csv.sh
  - fully-managed-sftp-source-json.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - .gitignore
  - config-SnowflakeSink.json
  - config-SnowflakeSink.txt
  - fully-managed-snowflake-iceberg-ext-volume-sink.sh
  - fully-managed-snowflake-iceberg-sink.sh
  - fully-managed-snowflake-sink.sh
  - README.md
  - stop.sh
  - ui.png
- - .gitignore
  - config-SnowflakeSource.json
  - config-SnowflakeSource.txt
  - fully-managed-snowflake-source.sh
  - README.md
  - stop.sh
  - ui.png
- - config-SolaceSink.json
  - config-SolaceSink.txt
  - docker-compose.yml
  - fully-managed-solace-sink.sh
  - ngrok.yml
  - README.md
  - show_queue_cmd
  - stop.sh
- - config-SolaceSource.json
  - config-SolaceSource.txt
  - create_queue_cmd
  - docker-compose.yml
  - fully-managed-solace-source.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - config-SplunkSink.json
  - config-SplunkSink.txt
  - default.yml
  - docker-compose.yml
  - fully-managed-splunk-sink.sh
  - ngrok.yml
  - README.md
  - stop.sh
- - config-ZendeskSource.json
  - config-ZendeskSource.txt
  - fully-managed-zendesk-source.sh
  - README.md
  - stop.sh
  - zendesk.jpg
- - .gitignore
  - diagram.png
  - docker-compose.yml
  - README.md
  - start.sh
  - stop.sh
- - docker-compose-executable-onprem-to-cloud-replicator.yml
  - docker-compose-executable-onprem-to-cloud.yml
  - executable-onprem-to-cloud-consumer.properties
  - executable-onprem-to-cloud-producer.properties
  - executable-onprem-to-cloud-replicator.properties
  - README.md
  - start.sh
  - stop.sh
- - .gitignore
  - connect-log4j.properties
  - connect-mirror-maker-template.properties
  - docker-compose.plaintext.yml
  - mirrormaker2.sh
  - README.md
  - stop.sh
- - docker-compose.yml
  - httpd_debian.sh
  - httpd_rhel.sh
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - sr-template.json
  - start.sh
  - stop.sh
- - connect-onprem-to-cloud-avro-with-sr-basic-auth.sh
  - connect-onprem-to-cloud-avro.sh
  - connect-onprem-to-cloud.sh
  - docker-compose-cloud-to-cloud.yml
  - docker-compose-connect-onprem-to-cloud-with-sr-basic-auth.yml
  - docker-compose-connect-onprem-to-cloud.yml
  - README.md
  - stop.sh
- - docker-compose.yml
  - kafka-rest.jaas-template.conf
  - README.md
  - start.sh
  - stop.sh
- - docker-compose.yml
  - jaas_config.file
  - jaas_config_8_plus.file
  - password-file
  - README.md
  - start.sh
  - stop.sh
- analyzer.py
- analyzer_cli.py
- html_report.py
- README.md
- recommendations.py
- requirements.txt
- sanitizer.py
- - starship.toml
  - zshrc
- kafka-docker-playground.yml
- README.md
- - active-mq-sink-mtls.sh
  - active-mq-sink.sh
  - activemq.xml
  - config-io.confluent.connect.jms.ActiveMqSinkConnector.json
  - config-io.confluent.connect.jms.ActiveMqSinkConnector.txt
  - docker-compose.plaintext.mtls.yml
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - active-mq-source-mtls.sh
  - active-mq-source.sh
  - activemq.xml
  - config-io.confluent.connect.activemq.ActiveMQSourceConnector.json
  - config-io.confluent.connect.activemq.ActiveMQSourceConnector.txt
  - docker-compose.plaintext.mtls.yml
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - amps-source.sh
  - docker-compose.plaintext.yml
  - README.md
  - Screenshot1.png
  - stop.sh
- - appdynamics-metrics-sink.sh
  - config-io.confluent.connect.appdynamics.metrics.AppDynamicsMetricsSinkConnector.json
  - config-io.confluent.connect.appdynamics.metrics.AppDynamicsMetricsSinkConnector.txt
  - docker-compose.plaintext.yml
  - README.md
  - Screenshot1.png
  - stop.sh
- - cloudwatch-assuming-iam-role-with-custom-awscredentialsprovider.sh
  - cloudwatch-with-assuming-iam-role.sh
  - cloudwatch.sh
  - config-io.confluent.connect.aws.cloudwatch.AwsCloudWatchSourceConnector.json
  - config-io.confluent.connect.aws.cloudwatch.AwsCloudWatchSourceConnector.txt
  - docker-compose.plaintext.assuming-iam-role-with-custom-awscredentialsprovider.yml
  - docker-compose.plaintext.with-assuming-iam-role.yml
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - cloudwatch-metrics-sink-with-assuming-iam-role.sh
  - cloudwatch-metrics-sink.sh
  - config-io.confluent.connect.aws.cloudwatch.metrics.AwsCloudWatchMetricsSinkConnector.json
  - config-io.confluent.connect.aws.cloudwatch.metrics.AwsCloudWatchMetricsSinkConnector.txt
  - docker-compose.plaintext.with-assuming-iam-role.yml
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - config-io.confluent.connect.aws.dynamodb.DynamoDbSinkConnector.json
  - config-io.confluent.connect.aws.dynamodb.DynamoDbSinkConnector.txt
  - docker-compose.plaintext.assuming-iam-role-with-custom-aws-credential-provider.yml
  - docker-compose.plaintext.proxy.yml
  - docker-compose.plaintext.with-assuming-iam-role-config.yml
  - docker-compose.plaintext.with-assuming-iam-role.yml
  - docker-compose.plaintext.with-custom-basic-aws-credentials-provider.yml
  - docker-compose.plaintext.yml
  - dynamodb-sink-assuming-iam-role-with-custom-aws-credential-provider.sh
  - dynamodb-sink-proxy.sh
  - dynamodb-sink-with-assuming-iam-role-config.sh
  - dynamodb-sink-with-assuming-iam-role.sh
  - dynamodb-sink-with-custom-basic-aws-credentials-provider.sh
  - dynamodb-sink.sh
  - README.md
  - stop.sh
- - config-io.confluent.connect.kinesis.KinesisSourceConnector.json
  - config-io.confluent.connect.kinesis.KinesisSourceConnector.txt
  - docker-compose.plaintext.assuming-iam-role-with-custom-awscredentialsprovider.yml
  - docker-compose.plaintext.nginx-proxy.yml
  - docker-compose.plaintext.with-assuming-iam-role.yml
  - docker-compose.plaintext.yml
  - kinesis-source-assuming-iam-role-with-custom-awscredentialsprovider.sh
  - kinesis-source-proxy.sh
  - kinesis-source-with-assuming-iam-role.sh
  - kinesis-source.sh
  - README.md
  - stop.sh
- - config-io.confluent.connect.aws.lambda.AwsLambdaSinkConnector.json
  - config-io.confluent.connect.aws.lambda.AwsLambdaSinkConnector.txt
  - docker-compose.plaintext.backup-and-restore-assuming-iam-role-with-custom-aws-credential-provider.yml
  - docker-compose.plaintext.with-assuming-iam-role.yml
  - docker-compose.plaintext.yml
  - lambda-sink-assuming-iam-role-with-custom-aws-credential-provider.sh
  - lambda-sink-with-assuming-iam-role.sh
  - lambda-sink.sh
  - README.md
  - stop.sh
- - .gitignore
  - config-io.confluent.connect.aws.redshift.RedshiftSinkConnector.json
  - config-io.confluent.connect.aws.redshift.RedshiftSinkConnector.txt
  - data.template
  - docker-compose.plaintext.with-assuming-iam-role.yml
  - docker-compose.plaintext.yml
  - README.md
  - redshift-sink-with-assuming-iam-role.sh
  - redshift-sink.sh
  - stop.sh
- - config-io.confluent.connect.s3.S3SinkConnector.json
  - config-io.confluent.connect.s3.S3SinkConnector.txt
  - docker-compose.plaintext.assuming-iam-role-with-custom-aws-credential-provider.yml
  - docker-compose.plaintext.irsa.yml
  - docker-compose.plaintext.proxy-basic-auth.yml
  - docker-compose.plaintext.proxy.with-assuming-iam-role.yml
  - docker-compose.plaintext.proxy.yml
  - docker-compose.plaintext.with-assuming-iam-role-config.yml
  - docker-compose.plaintext.with-assuming-iam-role.yml
  - docker-compose.plaintext.yml
  - README.md
  - s3-sink-assuming-iam-role-with-custom-aws-credential-provider.sh
  - s3-sink-irsa.sh
  - s3-sink-proxy-basic-auth.sh
  - s3-sink-proxy-with-assuming-iam-role.sh
  - s3-sink-proxy.sh
  - s3-sink-with-assuming-iam-role-config.sh
  - s3-sink-with-assuming-iam-role.sh
  - s3-sink.sh
  - stop.sh
- - config-io.confluent.connect.s3.S3SinkConnector.json
  - config-io.confluent.connect.s3.S3SinkConnector.txt
  - config-io.confluent.connect.s3.source.S3SourceConnector.json
  - config-io.confluent.connect.s3.source.S3SourceConnector.txt
  - docker-compose.plaintext.backup-and-restore-assuming-iam-role-with-custom-aws-credential-provider.yml
  - docker-compose.plaintext.backup-and-restore-proxy.yml
  - docker-compose.plaintext.backup-and-restore.with-assuming-iam-role-config.yml
  - docker-compose.plaintext.backup-and-restore.with-assuming-iam-role.yml
  - docker-compose.plaintext.backup-and-restore.yml
  - docker-compose.plaintext.generalized.yml
  - generalized.quickstart.json
  - README.md
  - s3-source-backup-and-restore-assuming-iam-role-with-custom-aws-credential-provider.sh
  - s3-source-backup-and-restore-proxy.sh
  - s3-source-backup-and-restore-with-assuming-iam-role-config.sh
  - s3-source-backup-and-restore-with-assuming-iam-role.sh
  - s3-source-backup-and-restore.sh
  - s3-source-generalized.sh
  - stop.sh
- - config-io.confluent.connect.sqs.source.SqsSourceConnector.json
  - config-io.confluent.connect.sqs.source.SqsSourceConnector.txt
  - docker-compose.plaintext.assuming-iam-role-with-custom-aws-credential-provider.yml
  - docker-compose.plaintext.proxy.yml
  - docker-compose.plaintext.with-assuming-iam-role.yml
  - docker-compose.plaintext.yml
  - README.md
  - send-message-batch.json
  - sqs-source-assuming-iam-role-with-custom-aws-credential-provider.sh
  - sqs-source-proxy.sh
  - sqs-source-with-assuming-iam-role.sh
  - sqs-source.sh
  - stop.sh
- - .gitignore
  - azure-blob-storage-sink-proxy.sh
  - azure-blob-storage-sink.sh
  - config-io.confluent.connect.azure.blob.AzureBlobStorageSinkConnector.json
  - config-io.confluent.connect.azure.blob.AzureBlobStorageSinkConnector.txt
  - data.template
  - docker-compose.plaintext.proxy.yml
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - .gitignore
  - azure-blob-storage-source-backup-and-restore.sh
  - azure-blob-storage-source-generalized.sh
  - azure-blob-storage-source-proxy-backup-and-restore.sh
  - config-io.confluent.connect.azure.blob.AzureBlobStorageSinkConnector.json
  - config-io.confluent.connect.azure.blob.AzureBlobStorageSinkConnector.txt
  - config-io.confluent.connect.azure.blob.storage.AzureBlobStorageSourceConnector.json
  - config-io.confluent.connect.azure.blob.storage.AzureBlobStorageSourceConnector.txt
  - data.template
  - docker-compose.plaintext.backup-and-restore.yml
  - docker-compose.plaintext.generalized.yml
  - docker-compose.plaintext.proxy.backup-and-restore.yml
  - generalized.quickstart.json
  - README.md
  - stop.sh
- - .gitignore
  - azure-cognitive-search-sink-proxy.sh
  - azure-cognitive-search-sink.sh
  - config-io.confluent.connect.azure.search.AzureSearchSinkConnector.json
  - config-io.confluent.connect.azure.search.AzureSearchSinkConnector.txt
  - data.template
  - docker-compose.plaintext.proxy.yml
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - .gitignore
  - azure-cosmosdb-sink.sh
  - config-com.azure.cosmos.kafka.connect.sink.CosmosDBSinkConnector.json
  - config-com.azure.cosmos.kafka.connect.sink.CosmosDBSinkConnector.txt
  - data.template
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - .gitignore
  - azure-cosmosdb-source.sh
  - config-com.azure.cosmos.kafka.connect.source.CosmosDBSourceConnector.json
  - config-com.azure.cosmos.kafka.connect.source.CosmosDBSourceConnector.txt
  - data.template
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - .gitignore
  - azure-data-lake-storage-gen2-sink.sh
  - config-io.confluent.connect.azure.datalake.gen2.AzureDataLakeGen2SinkConnector.json
  - config-io.confluent.connect.azure.datalake.gen2.AzureDataLakeGen2SinkConnector.txt
  - data.template
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - .gitignore
  - azure-event-hubs-source.sh
  - config-io.confluent.connect.azure.eventhubs.EventHubsSourceConnector.json
  - config-io.confluent.connect.azure.eventhubs.EventHubsSourceConnector.txt
  - data.template
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - .gitignore
  - azure-functions-sink.sh
  - config-io.confluent.connect.azure.functions.AzureFunctionsSinkConnector.json
  - config-io.confluent.connect.azure.functions.AzureFunctionsSinkConnector.txt
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - .gitignore
  - azure-service-bus-source.sh
  - config-io.confluent.connect.azure.servicebus.ServiceBusSourceConnector.json
  - config-io.confluent.connect.azure.servicebus.ServiceBusSourceConnector.txt
  - data.template
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - .gitignore
  - azure-synapse-analytics-sink.sh
  - config-io.confluent.connect.azuresqldw.AzureSqlDwSinkConnector.json
  - config-io.confluent.connect.azuresqldw.AzureSqlDwSinkConnector.txt
  - data.template
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - cassandra-sink.sh
  - config-io.confluent.connect.cassandra.CassandraSinkConnector.json
  - config-io.confluent.connect.cassandra.CassandraSinkConnector.txt
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - .gitignore
  - cdc-oracle19-cdb-table-mtls-db-auth.sh
  - cdc-oracle19-cdb-table-mtls.sh
  - cdc-oracle19-cdb-table-ssl.sh
  - cdc-oracle19-cdb-table.sh
  - cdc-oracle19-pdb-mview.sh
  - cdc-oracle19-pdb-table-mtls-db-auth.sh
  - cdc-oracle19-pdb-table-mtls.sh
  - cdc-oracle19-pdb-table-ssl.sh
  - cdc-oracle19-pdb-table.sh
  - config-io.confluent.connect.oracle.cdc.OracleCdcSourceConnector.json
  - config-io.confluent.connect.oracle.cdc.OracleCdcSourceConnector.txt
  - docker-compose.plaintext.cdb-table-mtls.yml
  - docker-compose.plaintext.cdb-table-ssl.yml
  - docker-compose.plaintext.cdb-table.yml
  - docker-compose.plaintext.pdb-table-mtls.yml
  - docker-compose.plaintext.pdb-table-ssl.yml
  - docker-compose.plaintext.pdb-table.yml
  - README.md
  - Screenshot1.png
  - stop.sh
- - .gitignore
  - cdc-oracle21-cdb-table-mtls-db-auth.sh
  - cdc-oracle21-cdb-table-mtls.sh
  - cdc-oracle21-cdb-table-ssl.sh
  - cdc-oracle21-cdb-table.sh
  - cdc-oracle21-pdb-mview.sh
  - cdc-oracle21-pdb-table-mtls-db-auth.sh
  - cdc-oracle21-pdb-table-mtls.sh
  - cdc-oracle21-pdb-table-ssl.sh
  - cdc-oracle21-pdb-table.sh
  - config-io.confluent.connect.oracle.cdc.OracleCdcSourceConnector.json
  - docker-compose.plaintext.cdb-table-mtls.yml
  - docker-compose.plaintext.cdb-table-ssl.yml
  - docker-compose.plaintext.cdb-table.yml
  - docker-compose.plaintext.pdb-table-mtls.yml
  - docker-compose.plaintext.pdb-table-ssl.yml
  - docker-compose.plaintext.pdb-table.yml
  - README.md
  - Screenshot1.png
  - stop.sh
- - .gitignore
  - cdc-xstream-oracle19-blocking-snapshot-kafka-signal.sh
  - cdc-xstream-oracle19-blocking-snapshot.sh
  - cdc-xstream-oracle19-mtls-wallet.sh
  - cdc-xstream-oracle19-ssl-wallet.sh
  - cdc-xstream-oracle19-ssl.sh
  - cdc-xstream-oracle19.sh
  - config-io.confluent.connect.oracle.xstream.cdc.OracleXStreamSourceConnector.json
  - config-io.confluent.connect.oracle.xstream.cdc.OracleXStreamSourceConnector.txt
  - docker-compose.plaintext.ssl.yml
  - docker-compose.plaintext.yml
  - README.md
  - Screenshot1.png
  - stop.sh
- - clickhouse-sink.sh
  - config-com.clickhouse.kafka.connect.ClickHouseSinkConnector.json
  - config-com.clickhouse.kafka.connect.ClickHouseSinkConnector.txt
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - config-com.couchbase.connect.kafka.CouchbaseSinkConnector.json
  - config-com.couchbase.connect.kafka.CouchbaseSinkConnector.txt
  - couchbase-sink.sh
  - docker-compose.plaintext.yml
  - README.md
  - Screenshot1.png
  - stop.sh
- - config-com.couchbase.connect.kafka.CouchbaseSourceConnector.json
  - config-com.couchbase.connect.kafka.CouchbaseSourceConnector.txt
  - couchbase-source.sh
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - .gitignore
  - config-io.confluent.connect.databricks.deltalake.DatabricksDeltaLakeSinkConnector.json
  - config-io.confluent.connect.databricks.deltalake.DatabricksDeltaLakeSinkConnector.txt
  - databricks-delta-lake-sink.sh
  - docker-compose.plaintext.yml
  - README.md
  - screenshot1.jpg
  - stop.sh
- - config-io.confluent.connect.diode.sink.DataDiodeSinkConnector.json
  - config-io.confluent.connect.diode.sink.DataDiodeSinkConnector.txt
  - config-io.confluent.connect.diode.source.DataDiodeSourceConnector.json
  - config-io.confluent.connect.diode.source.DataDiodeSourceConnector.txt
  - datadiode.sh
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - api_key_dd.png
  - app_key_dd.png
  - datadog-logs-sink.sh
  - dd_logs.png
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - config-io.confluent.connect.datadog.metrics.DatadogMetricsSinkConnector.json
  - config-io.confluent.connect.datadog.metrics.DatadogMetricsSinkConnector.txt
  - datadog-metrics-sink.sh
  - docker-compose.plaintext.yml
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - stop.sh
- - config-io.confluent.kafka.connect.datagen.DatagenConnector.json
  - config-io.confluent.kafka.connect.datagen.DatagenConnector.txt
  - datagen-source.sh
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - .gitignore
  - debezium-mariadb-source.sh
  - docker-compose.plaintext.yml
  - mysql-gtid.cnf
  - mysql-init.sql
  - mysql.cnf
  - README.md
  - stop.sh
- - .gitignore
  - config-io.debezium.connector.mongodb.MongoDbConnector.json
  - config-io.debezium.connector.mongodb.MongoDbConnector.txt
  - debezium-mongodb-source-incremental-snapshot-kafka-signal.sh
  - debezium-mongodb-source-incremental-snapshot.sh
  - debezium-mongodb-source-ssl.sh
  - debezium-mongodb-source.sh
  - docker-compose.plaintext.ssl.yml
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - config-io.debezium.connector.mysql.MySqlConnector.json
  - config-io.debezium.connector.mysql.MySqlConnector.txt
  - debezium-mysql-source-readonly-inc-snapshot.sh
  - debezium-mysql-source.sh
  - docker-compose.plaintext-ro-inc-snapshot.yml
  - docker-compose.plaintext.yml
  - mysql-gtid.cnf
  - mysql-init.sql
  - mysql.cnf
  - README.md
  - stop.sh
- - .gitignore
  - debezium-oracle19.sh
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - config-io.debezium.connector.postgresql.PostgresConnector.json
  - config-io.debezium.connector.postgresql.PostgresConnector.txt
  - debezium-postgres-source-incremental-snapshot-kafka-signal.sh
  - debezium-postgres-source-incremental-snapshot.sh
  - debezium-postgres-source-mtls.sh
  - debezium-postgres-source-partitioned-tables.sh
  - debezium-postgres-source-ssl.sh
  - debezium-postgres-source.sh
  - docker-compose.plaintext.mtls.yml
  - docker-compose.plaintext.ssl.yml
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - config-io.debezium.connector.sqlserver.SqlServerConnector.json
  - config-io.debezium.connector.sqlserver.SqlServerConnector.txt
  - debezium-sqlserver-source-incremental-snapshot-kafka-signal.sh
  - debezium-sqlserver-source-incremental-snapshot.sh
  - debezium-sqlserver-source-ssl.sh
  - debezium-sqlserver-source-standalone-worker.sh
  - debezium-sqlserver-source.sh
  - docker-compose.plaintext.ssl.yml
  - docker-compose.plaintext.standalone-worker.yml
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - config-io.debezium.connector.postgresql.PostgresConnector.json
  - config-io.debezium.connector.postgresql.PostgresConnector.txt
  - debezium-timescaledb-source.sh
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - docker-compose.plaintext.yml
  - elasticsearch-cloud-sink.sh
  - README.md
  - screenshot1.jpg
  - screenshot2.jpg
  - screenshot3.jpg
  - stop.sh
- - config-io.confluent.connect.elasticsearch.ElasticsearchSinkConnector.json
  - config-io.confluent.connect.elasticsearch.ElasticsearchSinkConnector.txt
  - docker-compose.plaintext.yml
  - elasticsearch-sink.sh
  - README.md
  - stop.sh
- - docker-compose.plaintext.yml
  - filestream-sink-external-schemas-in-json-converter.sh
  - README.md
  - stop.sh
- - .gitignore
  - config-io.streamthoughts.kafka.connect.filepulse.source.FilePulseSourceConnector.json
  - config-io.streamthoughts.kafka.connect.filepulse.source.FilePulseSourceConnector.txt
  - connect-file-pulse-quickstart-csv-1x.json
  - connect-file-pulse-quickstart-csv-2x.json
  - csv.sh
  - data.template
  - docker-compose.plaintext.s3.yml
  - docker-compose.plaintext.yml
  - json.sh
  - README.md
  - s3-csv.sh
  - s3-json.sh
  - stop.sh
  - xml.sh
- - .gitignore
  - config-org.apache.kafka.connect.file.FileStreamSinkConnector.json
  - config-org.apache.kafka.connect.file.FileStreamSinkConnector.txt
  - docker-compose.plaintext.yml
  - filestream-sink.sh
  - README.md
  - stop.sh
- - .gitignore
  - config-org.apache.kafka.connect.file.FileStreamSourceConnector.json
  - config-org.apache.kafka.connect.file.FileStreamSourceConnector.txt
  - docker-compose.plaintext.yml
  - filestream-source.sh
  - README.md
  - stop.sh
- - docker-compose.plaintext.yml
  - ftps-sink.sh
  - README.md
  - stop.sh
- - docker-compose.plaintext.yml
  - ftps-source.sh
  - README.md
  - stop.sh
- - config-com.wepay.kafka.connect.bigquery.BigQuerySinkConnector.json
  - config-com.wepay.kafka.connect.bigquery.BigQuerySinkConnector.txt
  - docker-compose.plaintext.yml
  - gcp-bigquery-sink.sh
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - Screenshot3.png
  - Screenshot4.png
  - stop.sh
- - config-io.confluent.connect.gcp.bigtable.BigtableSinkConnector.json
  - config-io.confluent.connect.gcp.bigtable.BigtableSinkConnector.txt
  - docker-compose.plaintext.proxy.yml
  - docker-compose.plaintext.yml
  - gcp-bigtable-sink-proxy.sh
  - gcp-bigtable-sink.sh
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - Screenshot3.png
  - Screenshot4.png
  - Screenshot5.png
  - stop.sh
- - config-io.confluent.connect.gcp.functions.GoogleCloudFunctionsSinkConnector.json
  - config-io.confluent.connect.gcp.functions.GoogleCloudFunctionsSinkConnector.txt
  - docker-compose.plaintext.yml
  - google-cloud-functions-sink.sh
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - stop.sh
- - docker-compose.plaintext.yml
  - gcp-dataproc-sink.sh
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - Screenshot3.png
  - Screenshot4.png
  - Screenshot5.png
  - stop.sh
- - config-io.confluent.connect.firebase.FirebaseSinkConnector.json
  - config-io.confluent.connect.firebase.FirebaseSinkConnector.txt
  - docker-compose.plaintext.yml
  - gcp-firebase-sink.sh
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - Screenshot3.png
  - Screenshot4.png
  - Screenshot5.png
  - Screenshot6.png
  - Screenshot7.png
  - Screenshot8.png
  - stop.sh
- - config-io.confluent.connect.firebase.FirebaseSourceConnector.json
  - config-io.confluent.connect.firebase.FirebaseSourceConnector.txt
  - docker-compose.plaintext.yml
  - gcp-firebase-source.sh
  - musicBlog.json
  - README.md
  - Screenshot1.png
  - Screenshot10.png
  - Screenshot2.png
  - Screenshot3.png
  - Screenshot4.png
  - Screenshot5.png
  - Screenshot6.png
  - Screenshot7.png
  - Screenshot8.png
  - Screenshot9.png
  - stop.sh
- - .gitignore
  - config-io.confluent.connect.gcs.GcsSinkConnector.json
  - config-io.confluent.connect.gcs.GcsSinkConnector.txt
  - docker-compose.yml
  - gcs-sink.sh
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - Screenshot3.png
  - Screenshot4.png
  - stop.sh
- - config-io.confluent.connect.gcs.GcsSinkConnector.json
  - config-io.confluent.connect.gcs.GcsSinkConnector.txt
  - config-io.confluent.connect.gcs.GcsSourceConnector.json
  - config-io.confluent.connect.gcs.GcsSourceConnector.txt
  - docker-compose.plaintext.backup-and-restore.yml
  - docker-compose.plaintext.generalized.yml
  - gcs-source-backup-and-restore.sh
  - gcs-source-generalized.sh
  - generalized.quickstart.json
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - Screenshot3.png
  - Screenshot4.png
  - stop.sh
- - config-com.google.pubsub.kafka.sink.CloudPubSubSinkConnector.json
  - config-com.google.pubsub.kafka.sink.CloudPubSubSinkConnector.txt
  - docker-compose.plaintext.yml
  - gcp-google-pubsub-sink.sh
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - Screenshot3.png
  - Screenshot4.png
  - stop.sh
- - config-com.google.pubsub.kafka.source.CloudPubSubSourceConnector.json
  - config-com.google.pubsub.kafka.source.CloudPubSubSourceConnector.txt
  - docker-compose.plaintext.yml
  - gcp-google-pubsub-source.sh
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - Screenshot3.png
  - Screenshot4.png
  - stop.sh
- - config-io.confluent.connect.gcp.pubsub.PubSubSourceConnector.json
  - config-io.confluent.connect.gcp.pubsub.PubSubSourceConnector.txt
  - docker-compose.plaintext.nginx-proxy.yml
  - docker-compose.plaintext.yml
  - gcp-pubsub-source-nginx-proxy.sh
  - gcp-pubsub-source.sh
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - Screenshot3.png
  - Screenshot4.png
  - stop.sh
- - config-io.confluent.connect.gcp.spanner.SpannerSinkConnector.json
  - config-io.confluent.connect.gcp.spanner.SpannerSinkConnector.txt
  - docker-compose.plaintext.proxy.yml
  - docker-compose.plaintext.yml
  - gcp-spanner-sink-proxy.sh
  - gcp-spanner-sink.sh
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - Screenshot3.png
  - Screenshot4.png
  - stop.sh
- - config-io.confluent.connect.github.GithubSourceConnector.json
  - config-io.confluent.connect.github.GithubSourceConnector.txt
  - docker-compose.plaintext.yml
  - github-source.sh
  - README.md
  - Screenshot1.png
  - Screenshot2.png
  - Screenshot3.png
  - Screenshot4.png
  - stop.sh
- - .gitignore
  - docker-compose.plaintext.yml
  - graphdb-sink.sh
  - README.md
  - stop.sh
- - .gitignore
  - config-io.confluent.connect.hbase.HBaseSinkConnector.json
  - config-io.confluent.connect.hbase.HBaseSinkConnector.txt
  - docker-compose.plaintext.kerberos.yml
  - docker-compose.plaintext.yml
  - hbase-sink-kerberos.sh
  - hbase-sink.sh
  - README.md
  - stop.sh
- - .gitignore
  - config-io.confluent.connect.hdfs.HdfsSinkConnector.json
  - config-io.confluent.connect.hdfs.HdfsSinkConnector.txt
  - docker-compose.plaintext.ha-kerberos.yml
  - docker-compose.plaintext.yml
  - hadoop-hive.env
  - hdfs2-sink-ha-kerberos.sh
  - hdfs2-sink.sh
  - README.md
  - stop.sh
- - .gitignore
  - config-io.confluent.connect.hdfs.HdfsSinkConnector.json
  - config-io.confluent.connect.hdfs.HdfsSinkConnector.txt
  - config-io.confluent.connect.hdfs2.Hdfs2SourceConnector.json
  - config-io.confluent.connect.hdfs2.Hdfs2SourceConnector.txt
  - docker-compose.plaintext.yml
  - hadoop-hive.env
  - hadoop.env
  - hdfs2-source.sh
  - README.md
  - stop.sh
- - .gitignore
  - config-io.confluent.connect.hdfs3.Hdfs3SinkConnector.json
  - config-io.confluent.connect.hdfs3.Hdfs3SinkConnector.txt
  - docker-compose.hive4.yml
  - docker-compose.plaintext.ha-kerberos.yml
  - docker-compose.plaintext.yml
  - Dockerfile
  - hadoop-hive.env
  - hadoop.env
  - hdfs3-sink-ha-kerberos.sh
  - hdfs3-sink-hive4.sh
  - hdfs3-sink.sh
  - README.md
  - stop.sh
- - config-io.confluent.connect.hdfs3.Hdfs3SinkConnector.json
  - config-io.confluent.connect.hdfs3.Hdfs3SinkConnector.txt
  - config-io.confluent.connect.hdfs3.Hdfs3SourceConnector.json
  - config-io.confluent.connect.hdfs3.Hdfs3SourceConnector.txt
  - docker-compose.plaintext.yml
  - hadoop-hive.env
  - hadoop.env
  - hdfs3-source.sh
  - README.md
  - stop.sh
- - config-io.confluent.connect.omnisci.OmnisciSinkConnector.json
  - config-io.confluent.connect.omnisci.OmnisciSinkConnector.txt
  - docker-compose.plaintext.yml
  - heavy-ai-sink.sh
  - README.md
  - stop.sh
- - config-io.confluent.connect.http.HttpSinkConnector.json
  - config-io.confluent.connect.http.HttpSinkConnector.txt
  - docker-compose.plaintext.yml
  - http-elasticsearchv9-sink.sh
  - README.md
  - stop.sh
- - config-io.confluent.connect.http.HttpSinkConnector.json
  - config-io.confluent.connect.http.HttpSinkConnector.txt
  - docker-compose.plaintext.basic.auth.yml
  - docker-compose.plaintext.mtls.yml
  - docker-compose.plaintext.oauth2.yml
  - docker-compose.plaintext.proxy.yml
  - docker-compose.plaintext.ssl.basic.auth.yml
  - docker-compose.plaintext.yml
  - http_basic_auth-proxy.sh
  - http_basic_auth.sh
  - http_mtls_auth.sh
  - http_no_auth.sh
  - http_oauth2_auth.sh
  - http_ssl_basic_auth.sh
  - README.md
  - stop.sh
- - .gitignore
  - config-io.confluent.connect.http.HttpSourceConnector.json
  - config-io.confluent.connect.http.HttpSourceConnector.txt
  - docker-compose.plaintext.chaining-offset.yml
  - docker-compose.plaintext.cursor-pagination.yml
  - docker-compose.plaintext.no-auth-proxy.yml
  - docker-compose.plaintext.oauth2.yml
  - docker-compose.plaintext.simple-incrementing.yml
  - http-source-chaining-offset.sh
  - http-source-cursor-pagination.sh
  - http-source-no-auth-proxy.sh
  - http-source-oauth2.sh
  - http-source-simple-incrementing.sh
  - README.md
  - stop.sh
- - .gitignore
  - docker-compose.plaintext.oauth2.yml
  - docker-compose.plaintext.yml
  - http_v2_no_auth.sh
  - http_v2_oauth2_auth.sh
  - README.md
  - stop.sh
- - .gitignore
  - docker-compose.plaintext.chaining-offset.yml
  - docker-compose.plaintext.cursor-pagination.yml
  - docker-compose.plaintext.no-auth.yml
  - docker-compose.plaintext.oauth2.yml
  - docker-compose.plaintext.simple-incrementing.yml
  - http-v2-source-chaining-offset.sh
  - http-v2-source-cursor-pagination.sh
  - http-v2-source-no-auth.sh
  - http-v2-source-oauth2.sh
  - http-v2-source-simple-incrementing.sh
  - README.md
  - stop.sh
- - .gitignore
  - config-io.confluent.connect.jms.IbmMqSinkConnector.json
  - config-io.confluent.connect.jms.IbmMqSinkConnector.txt
  - docker-compose.plaintext.mtls.yml
  - docker-compose.plaintext.ssl.yml
  - docker-compose.plaintext.yml
  - ibm-mq-sink-eos.sh
  - ibm-mq-sink-mtls.sh
  - ibm-mq-sink-ssl.sh
  - ibm-mq-sink.sh
  - README.md
  - Screenshot1.png
  - stop.sh
- - .gitignore
  - config-io.confluent.connect.ibm.mq.IbmMQSourceConnector.json
  - config-io.confluent.connect.ibm.mq.IbmMQSourceConnector.txt
  - docker-compose.plaintext.bindings-mode.yml
  - docker-compose.plaintext.eos.yml
  - docker-compose.plaintext.mtls.yml
  - docker-compose.plaintext.ssl.yml
  - docker-compose.plaintext.yml
  - ibm-mq-bindings-mode.sh
  - ibm-mq-bytes-message.sh
  - ibm-mq-eos.sh
  - ibm-mq-mtls.sh
  - ibm-mq-ssl.sh
  - ibm-mq.sh
  - JmsProducer.java
  - README.md
  - Screenshot1.png
  - stop.sh
- - config-org.apache.iceberg.connect.IcebergSinkConnector.json
  - config-org.apache.iceberg.connect.IcebergSinkConnector.txt
  - docker-compose.plaintext.yml
  - iceberg-sink.sh
  - README.md
  - stop.sh
- - config-io.confluent.influxdb.InfluxDBSinkConnector.json
  - config-io.confluent.influxdb.InfluxDBSinkConnector.txt
  - docker-compose.plaintext.yml
  - influxdb-sink-with-tags.sh
  - influxdb-sink.sh
  - README.md
  - stop.sh
- - config-io.confluent.influxdb.source.InfluxdbSourceConnector.json
  - config-io.confluent.influxdb.source.InfluxdbSourceConnector.txt
  - docker-compose.plaintext.yml
  - influxdb-source.sh
  - README.md
  - stop.sh
- - .gitignore
  - athena-jdbc-source.sh
  - customers.sql
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - .gitignore
  - docker-compose.plaintext.yml
  - README.md
  - redshift-jdbc-sink.sh
  - stop.sh
- - .gitignore
  - config-io.confluent.connect.jdbc.JdbcSourceConnector.json
  - config-io.confluent.connect.jdbc.JdbcSourceConnector.txt
  - customers.sql
  - docker-compose.plaintext.yml
  - README.md
  - redshift-jdbc-source.sh
  - stop.sh
- - .gitignore
  - config-io.confluent.connect.jdbc.JdbcSourceConnector.json
  - config-io.confluent.connect.jdbc.JdbcSourceConnector.txt
  - data.template
  - docker-compose.plaintext.yml
  - jdbc-azure-synapse-analytics-source.sh
  - README.md
  - stop.sh
- - cockroachdb-jdbc.sh
  - config-io.confluent.connect.jdbc.JdbcSourceConnector.json
  - config-io.confluent.connect.jdbc.JdbcSourceConnector.txt
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - .gitignore
  - databricks-jdbc-sink.sh
  - docker-compose.plaintext.yml
  - README.md
  - stop.sh
- - .gitignore
  - databricks-jdbc-source.sh
  - README.md
.gitignore
.gitmodules
CLAUDE.md
CONTRIBUTING.md
LICENSE
README.md

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

kafka-docker-playground

File Explorer

Today's picks

Was this content helpful?

Recent Feedback

kafka-docker-playground

File Explorer

Today's picks

Was this content helpful?

Recent Feedback

Download README