clickhouse-kafka-connect
clickhouse-kafka-connect copied to clipboard
ClickHouse
ClickHouse Kafka Connector
Bumps com.diffplug.spotless from 6.25.0 to 7.0.2. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
Bumps [org.testcontainers:testcontainers](https://github.com/testcontainers/testcontainers-java) from 1.20.4 to 1.20.5. Release notes Sourced from org.testcontainers:testcontainers's releases. 1.20.5 What's Changed Add ServiceBusEmulatorContainer to Azure module (#9795) @nagyesta Add EventHubsEmulatorContainer to Azure module (#9665) @nagyesta Add...
Bumps com.github.gmazzo.buildconfig from 5.5.0 to 5.5.1. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...
**Describe the solution you'd like** examples in the docs for ingesting - a filed into a JSON column - a message into a JSON column
https://github.com/ClickHouse/clickhouse-kafka-connect/blob/fef6bb714d2cca61bead75f16dd9c09ea215b9c5/src/main/java/com/clickhouse/kafka/connect/sink/db/ClickHouseWriter.java#L611 **Example debezium record here trigger_id_uuid is empty, but not null** : ``` {"trigger_id_uuid":"", "more_":"...", "id":"123", __deleted":{"string":"true"}, "__ts_ms":{"long":111111111}, "__op":{"string":"d"}} ``` **Error trace:** ``` WorkerSinkTask{id=clickhouse_sink-0} Task threw an uncaught and unrecoverable...
KeeperMap doesn't obey "database" - we should add it to the key to help limit conflict.
**Is your feature request related to a problem? Please describe.** We have successfully set up the connector in AWS using MSK Connect, and this is working well. However, we are...
## Summary Memory reduction. ## Checklist Delete items not relevant to your PR: - [ ] Unit and integration tests covering the common scenarios were added - [ ] A...
We have made a major refactor in the Java Client. One of the outcomes is to move from `BinaryStreamUtils` to a new `SerializerUtils` for writing to the stream. A task...
- Allow for limited retries for exceptions (limited by exception code and/or all retriable exceptions) - Allow customizing the retriable exceptions list