Commit fde9ad3
authored
update (#1)
* airlock sync (#1)
* airlock sync
* empty commit
* Update docker-compose.plaintext.proxy.yml
* Update docker-compose.plaintext.yml
* Update docker-compose.plaintext.backup-and-restore.yml
* Update docker-compose.plaintext.proxy.backup-and-restore.yml
* Update connect-onprem-to-cloud.sh
* Update connect-onprem-to-cloud-avro.sh
* Update connect-onprem-to-cloud-avro-with-sr-basic-auth.sh
* Update cli_function.sh
* Update get-number-records.sh
* Update heap-dump.sh
* Update snippets.sh
* Update create-or-update.sh
* Update bashly.yml
* Features3 (#4)
* reproduction-models
* fix self certs
* 2.00.076.00.20240701.1
* wip (#5)
* update
* bump to 3.24.4
* fix for jdk17
* fix schema
* cleanup pushtopic
* Add HTTP Sink V2 Fully Managed example vdesabou#5885
* wip (#6)
* minor
* minor
* delete topic
* Add HTTP Source V2 Fully Managed example vdesabou#5884
* sleep 60
* fix
* wip (#7)
* debug
* MyLeadPushTopicsV2
* wip
* 7.7.1
* playground connector show-lag
* wip (#8)
* doing auth again
* 3.25.1
* wip
* wip
* jdk 17 fix
* 16092024 2 (#9)
* Add example for jsonata vdesabou#5756
* check does not work with CI for some reasons, only relying on lag
* Issue with adding tcpdump vdesabou#5917
* wip (#10)
* separate name for cloud
* delete
* Add Google Cloud Functions Gen 2 Sink Connector vdesabou#5869
* update (#12)
* 26092024 2 (#13)
* Add --initial-state option to "playground connector create-or-update" vdesabou#5929
* faker location
* wip (#14)
* 3.5.3
* playground connector show-lag issue when used with --environment ccloud example vdesabou#5943
* remove connect-jms-sag-um-source and connect-jms-sag-um-sink examples as Docker image is no longer provided by SAG vdesabou#5949
* wip
* wip (#15)
* vdesabou#5187
* delete retry
* test
* wip
* Add custom connector example for Tabular Iceberg sink vdesabou#5971
* minor
* topic produce: make nb_max_messages_to_generate configurable vdesabou#5976
* fix on linux1 parent a324a9d commit fde9ad3
File tree
1,367 files changed
+49412
-15399
lines changed- .devcontainer
- .github
- workflows
- .gitpod
- academy
- connect-connect-aws-s3-sink
- connect-connect-debezium-sqlserver-source
- connect-connect-jdbc-mysql-source
- ccloud
- audit-log-connector
- confluent-for-kubernetes
- connect-centralized-license
- custom-connector-connect-aws-s3-sink
- custom-connector-connect-iceberg-sink
- data
- notebooks
- .ipynb_checkpoints
- spark
- ipython/startup
- notebooks
- environment
- grafana
- config
- confluent
- provisioning
- dashboards
- datasources
- prometheus
- fm-active-mq-source
- fm-aws-cloudwatch-logs-source
- fm-aws-cloudwatch-metrics-sink
- fm-aws-dynamodb-cdc-source
- fm-aws-dynamodb-sink
- fm-aws-kinesis-source
- fm-aws-lambda-sink
- fm-aws-redshift-sink
- fm-aws-s3-sink
- fm-aws-s3-source
- fm-aws-sqs-source
- fm-azure-blob-storage-sink
- fm-azure-blob-storage-source
- fm-azure-cognitive-search-sink
- fm-azure-cosmosdb-sink
- fm-azure-cosmosdb-source
- fm-azure-cosmosdb-v2-sink
- azure-cosmos-client
- fm-azure-cosmosdb-v2-source
- azure-cosmos-client
- fm-azure-data-lake-storage-gen2-sink
- fm-azure-event-hubs-source
- simple-send
- fm-azure-functions-sink
- fm-azure-log-analytics-sink
- fm-azure-service-bus-source
- QueuesGettingStarted
- fm-azure-synapse-analytics-sink
- fm-cdc-oracle11-source
- fm-cdc-oracle19-source
- oracle-datagen
- src/main
- java/com/confluent/oracle/datagen
- connection
- domain
- resources
- fm-cdc-xstream-oracle19-source
- oracle-datagen
- src/main
- java/com/confluent/oracle/datagen
- connection
- domain
- resources
- ssl
- fm-clickhouse-sink
- fm-couchbase-sink
- fm-couchbase-source
- fm-databricks-delta-lake-sink
- fm-datagen-source
- fm-debezium-mariadb-source
- mysql-datagen
- src/main
- java/com/confluent/mysql/datagen
- connection
- domain
- resources
- fm-debezium-mysql-legacy-source
- mysql-datagen/src/main/resources
- fm-debezium-mysql-v2-source
- mysql-datagen/src/main/resources
- fm-debezium-postgresql-legacy-source
- postgres-datagen/src/main/resources
- fm-debezium-postgresql-v2-source
- postgres-datagen/src/main/resources
- fm-debezium-sqlserver-legacy-source
- sqlserver-datagen/src/main/resources
- fm-debezium-sqlserver-v2-source
- sqlserver-datagen/src/main/resources
- fm-gcp-bigquery-legacy-sink
- fm-gcp-bigquery-v2-sink
- fm-gcp-bigtable-sink
- fm-gcp-cloud-functions-gen2-sink
- fm-gcp-cloud-functions-legacy-sink
- fm-gcp-gcs-sink
- fm-gcp-gcs-source
- fm-gcp-pubsub-source
- fm-gcp-spanner-sink
- fm-http-sink
- fm-http-source
- fm-http-v2-sink
- fm-http-v2-source
- fm-jdbc-mysql-source
- fm-jdbc-oracle19-sink
- fm-jdbc-oracle19-source
- fm-jdbc-sqlserver-sink
- fm-jdbc-sqlserver-source
- fm-mqtt-source
- mtls
- fm-opensearch-sink
- fm-rabbitmq-sink
- security
- fm-rabbitmq-source
- security
- fm-salesforce-bulkapi-2-0-sink
- fm-salesforce-cdc-source
- fm-salesforce-pushtopics-source
- fm-salesforce-sobject-sink
- fm-servicenow-sink
- fm-servicenow-source
- fm-servicenow-v2-source
- fm-snowflake-sink
- fm-snowflake-source
- fm-solace-sink
- fm-splunk-sink
- haproxy
- migrate-schemas-to-confluent-cloud
- mirrormaker2
- multiple-sr-hybrid
- replicator
- rest-proxy-security-plugin
- security
- schema-registry-security-plugin
- cloudformation
- dotfiles
- connect
- connect-active-mq-sink
- security
- connect-active-mq-source
- security
- connect-amps-source
- connect-appdynamics-metrics-sink
- connect-aws-cloudwatch-logs-source
- awscredentialsprovider
- src/main
- java/com/github/vdesabou
- resources
- connect-aws-cloudwatch-metrics-sink
- connect-aws-dynamodb-sink
- connect-aws-kinesis-source
- connect-aws-lambda-sink
- awscredentialsprovider
- connect-aws-redshift-sink
- connect-aws-s3-sink
- connect-aws-s3-source
- connect-aws-sqs-source
- awscredentialsprovider-v2
- src/main
- java/com/github/vdesabou
- resources
- connect-azure-blob-storage-sink
- connect-azure-blob-storage-source
- connect-azure-cognitive-search-sink
- connect-azure-cosmosdb-sink
- connect-azure-cosmosdb-source
- connect-azure-data-lake-storage-gen1-sink
- connect-azure-data-lake-storage-gen2-sink
- connect-azure-event-hubs-source
- simple-send
- connect-azure-functions-sink
- connect-azure-service-bus-source
- QueuesGettingStarted
- connect-azure-synapse-analytics-sink
- connect-cassandra-sink
- connect-cdc-oracle11-source
- oracle-datagen/src/main/resources
- connect-cdc-oracle12-source
- oracle-datagen/src/main/resources
- connect-cdc-oracle18-source
- oracle-datagen/src/main/resources
- connect-cdc-oracle19-source
- oracle-datagen/src/main/resources
- connect-cdc-oracle21-source
- oracle-datagen/src/main/resources
- connect-cdc-xstream-oracle19-source
- oracle-datagen
- src/main
- java/com/confluent/oracle/datagen
- connection
- domain
- resources
- ssl
- client
- connect-couchbase-sink
- json-producer
- connect-databricks-delta-lake-sink
- connect-datadiode-source-sink
- connect-datadog-logs-sink
- connect-datadog-metrics-sink
- connect-datagen-source
- connect-debezium-mariadb-source
- mysql-datagen
- src/main
- java/com/confluent/mysql/datagen
- connection
- domain
- resources
- connect-debezium-mongodb-source
- connect-debezium-mysql-source
- mysql-datagen/src/main/resources
- connect-debezium-oracle19-source
- oracle-datagen/src/main/resources
- connect-debezium-postgresql-source
- postgres-datagen/src/main/resources
- connect-debezium-sqlserver-source
- sqlserver-datagen/src/main/resources
- connect-elasticsearch-cloud-sink
- connect-elasticsearch-sink
- connect-filepulse-source
- connect-filestream-sink
- connect-filestream-source
- connect-ftps-sink
- security
- connect-ftps-source
- security
- connect-gcp-bigquery-sink
- connect-gcp-bigtable-sink
- connect-gcp-cloud-functions-sink
- connect-gcp-dataproc-sink
- connect-gcp-firebase-sink
- connect-gcp-firebase-source
- connect-gcp-gcs-sink
- connect-gcp-gcs-source
- connect-gcp-google-pubsub-sink
- connect-gcp-google-pubsub-source
- connect-gcp-pubsub-source
- connect-gcp-spanner-sink
- connect-github-source
- connect-graphdb-sink
- connect-hbase-sink
- connect-hdfs2-sink
- jprofiler
- connect-hdfs2-source
- connect-hdfs3-sink
- connect-hdfs3-source
- connect-heavy-ai-sink
- connect-http-cdc-source
- nginx-proxy
- connect-http-sink
- httpserver
- connect-http-source
- connect-ibm-mq-sink
- security
- connect-ibm-mq-source
- security
- connect-iceberg-sink
- spark
- connect-influxdb-sink
- connect-influxdb-source
- connect-jdbc-aws-athena-source
- connect-jdbc-aws-redshift-sink
- connect-jdbc-aws-redshift-source
- connect-jdbc-azure-synapse-analytics-source
- connect-jdbc-cockroachdb-source
- connect-jdbc-databricks-sink
- databricks
- connect-jdbc-databricks-source
- databricks
- connect-jdbc-gcp-bigquery-source
- connect-jdbc-hive-sink
- connect-jdbc-hive-source
- connect-jdbc-ibmdb2-sink
- connect-jdbc-ibmdb2-source
- connect-jdbc-mariadb-sink
- connect-jdbc-mariadb-source
- connect-jdbc-mysql-sink
- connect-jdbc-mysql-source
- mysql-datagen/src/main/resources
- connect-jdbc-oracle11-sink
- connect-jdbc-oracle11-source
- oracle-datagen/src/main/resources
- connect-jdbc-oracle12-sink
- connect-jdbc-oracle12-source
- oracle-datagen/src/main/resources
- connect-jdbc-oracle19-sink
- connect-jdbc-oracle19-source
- oracle-datagen/src/main/resources
- connect-jdbc-oracle21-sink
- connect-jdbc-oracle21-source
- oracle-datagen/src/main/resources
- connect-jdbc-postgresql-sink
- connect-jdbc-postgresql-source
- postgres-datagen/src/main/resources
- connect-jdbc-sap-hana-sink
- connect-jdbc-sap-hana-source
- connect-jdbc-singlestore-source
- connect-jdbc-snowflake-sink
- connect-jdbc-snowflake-source
- connect-jdbc-sqlserver-sink
- connect-jdbc-sqlserver-source
- sqlserver-datagen/src/main/resources
- connect-jdbc-sybase-sink
- connect-jdbc-sybase-source
- connect-jdbc-vertica-sink
- producer
- connect-jira-source
- connect-jms-active-mq-sink
- connect-jms-active-mq-source
- connect-jms-oracle19-sink
- connect-jms-oracle19-source
- connect-jms-oracle21-sink
- connect-jms-oracle21-source
- connect-jms-sag-um-sink
- connect-jms-sag-um-source
- connect-jms-solace-sink
- connect-jms-solace-source
- connect-jms-tibco-sink
- connect-jms-tibco-source
- connect-jms-weblogic-sink
- connect-jms-weblogic-source
- connect-kudu-sink
- connect-kudu-source
- connect-lenses-active-mq-source
- connect-mapr-sink
- connect-marketo-source
- connect-minio-s3-sink
- connect-mongodb-sink
- connect-mongodb-source
- connect-mqtt-sink
- security
- connect-mqtt-source
- security
- connect-neo4j-sink
- connect-omnisci-sink
- connect-pagerduty-sink
- connect-pivotal-gemfire-sink
- connect-prometheus-sink
- connect-rabbitmq-sink
- security
- connect-rabbitmq-source
- security
- connect-redis-sink
- connect-replicator
- connect-salesforce-bulkapi-sink
- connect-salesforce-bulkapi-source
- connect-salesforce-cdc-source
- connect-salesforce-platform-events-sink
- connect-salesforce-platform-events-source
- connect-salesforce-pushtopics-source
- connect-salesforce-sobject-sink
- connect-sap-hana-sink
- connect-servicenow-sink
- connect-servicenow-source
- connect-sftp-sink
- connect-sftp-source
- connect-singlestore-sink
- connect-snmp-source
- connect-snowflake-sink
- connect-solace-sink
- connect-solace-source
- connect-splunk-s2s-source
- connect-splunk-sink
- connect-splunk-source
- connect-spool-dir-source
- connect-syslog-source
- connect-tibco-sink
- connect-tibco-source
- connect-vertica-sink
- connect-weblogic-source
- connect-zendesk-source
- docs
- environment
- 2way-ssl
- conduktor
- security
- kerberos
- client
- conduktor
- kraft-external-plaintext
- kraft-plaintext
- ldap-authorizer-sasl-plain
- ldap-sasl-plain
- mdc-kerberos
- client
- mdc-plaintext
- mdc-sasl-plain
- plaintext
- conduktor
- control-center-v2-config
- grafana/provisioning/dashboards
- jmx-exporter
- prometheus
- rbac-sasl-plain
- scripts/helper
- sasl-plain
- conduktor
- sasl-scram
- conduktor
- sasl-ssl
- conduktor
- security
- ssl_kerberos
- client
- conduktor
- security
- flink
- conf
- flink_app_mode
- flink_session_mode
- flink_session_sql_mode
- images
- icons
- ksqldb
- benchmarking-scenarios
- handle-empty-array-explode
- handle-null-value-coalesce
- manage-deserialization-errors
- many-many-join
- materialized-view
- nested-json
- schema-evolution
- schema-inference-with-id
- simple-example-vanilla-producer
- stream-table-join-timestamp-based-join-failure
- udf-logging
- multi-data-center
- cluster-linking
- sasl-plain-acl
- kafka-offsets-migrator
- mirrormaker2
- one-to-many-with-offsets-translation
- replicator-connect
- replicator-executable
- operator
- rbac
- replicator-tls-only
- other
- audit-logs
- broker-schema-validation
- connect-override-policy-sftp-sink
- connect-override-policy-sftp-source
- connect-secret-registry
- control-center-readonly-mode
- create-topic-policy/create-topic-policy
- custom-smt
- http-proxy-schema-registry
- jms-client
- jms-client
- kafka-connect-jsonata
- ldap-authorizer-with-ldap-failover
- security
- monitoring-cluster-linking
- monitoring-demo
- streams
- src/main/java/com/github/vdesabou
- monitoring-sink-latency
- mqtt-proxy
- rbac-with-anonymous-sr
- rbac-with-azure-ad
- rbac-with-sr-basic-auth-acl
- rebalancer
- rest-proxy-security-plugin
- schema-format-avro-with-key
- schema-format-avro
- schema-format-json-schema-with-key
- schema-format-json-schema
- schema-format-protobuf-with-key
- producer
- schema-format-protobuf
- producer
- src/main/proto
- schema-registry-security-plugin
- secrets-management
- syslog-logstash-ksqldb
- tiered-storage-with-aws
- schema-registry
- data-contracts
- kafka-avro-console-producer-union
- multiple-event-types-in-topic
- use-diffrent-key-value-serializer-console-producer
- scripts
- cli
- docs-template
- predefined-schemas/json
- snippets
- src
- commands
- config
- open-grafana-in-browser
- connector-plugin
- connector
- offsets
- container
- debug
- ec2
- sync-repro-folder
- repro
- schema
- state
- tcp-proxy
- tools
- topic
- jscissors
- lib
- validations
- ssl
- templates/shell-script-command-completion
- tools/datadog
- troubleshooting
- adding-connect-worker
- admin-client-issue-when-broker-down
- adminclient
- connect-worker-restart-while-broker-down
- force-delete-connector-with-tombstone
- forward-compatibility-and-specific-records
- ksql-avro-ccloud
- ksqldb-fail-on-production-error
- log-compaction
- small-retention-timestamp-microseconds
- producer
- small-retention-unknown-producer-id
- consumer
- producer
- spring
- small-retention
- producer
- staled-consumer-group-behaviour
- producer
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
1,367 files changed
+49412
-15399
lines changedThis file was deleted.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | 2 | | |
3 | 3 | | |
4 | | - | |
| 4 | + | |
5 | 5 | | |
6 | | - | |
7 | | - | |
8 | | - | |
9 | | - | |
10 | | - | |
11 | | - | |
12 | | - | |
13 | | - | |
14 | | - | |
15 | | - | |
16 | | - | |
| 6 | + | |
| 7 | + | |
17 | 8 | | |
18 | | - | |
19 | | - | |
20 | | - | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
| 60 | + | |
| 61 | + | |
| 62 | + | |
| 63 | + | |
| 64 | + | |
| 65 | + | |
| 66 | + | |
| 67 | + | |
| 68 | + | |
| 69 | + | |
| 70 | + | |
| 71 | + | |
| 72 | + | |
| 73 | + | |
| 74 | + | |
| 75 | + | |
| 76 | + | |
| 77 | + | |
| 78 | + | |
| 79 | + | |
| 80 | + | |
| 81 | + | |
| 82 | + | |
| 83 | + | |
| 84 | + | |
| 85 | + | |
| 86 | + | |
| 87 | + | |
21 | 88 | | |
22 | | - | |
23 | | - | |
24 | | - | |
25 | | - | |
26 | | - | |
27 | | - | |
28 | | - | |
29 | | - | |
30 | | - | |
31 | | - | |
32 | | - | |
| 89 | + | |
| 90 | + | |
| 91 | + | |
| 92 | + | |
| 93 | + | |
| 94 | + | |
33 | 95 | | |
34 | 96 | | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
0 commit comments