Skip to content

Commit 397227a

Browse files
author
Farooq Qaiser
committed
temp
1 parent 4c4b8f8 commit 397227a

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

README.md

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -57,6 +57,11 @@ contain the name of the table. Enabling `iceberg.tables.upsert-mode-enabled` wil
5757
preceded by an equality delete. Both CDC and upsert mode require an Iceberg V2 table with identity fields
5858
defined.
5959

60+
It is safe to reuse the same `iceberg.control.topic` for multiple connectors as this is expected to be a
61+
relatively low traffic topic. Connectors can distinguish between which messages are relevant to them by looking at
62+
the `iceberg.control.group-id` that is encoded inside each message for this purpose. Naturally, this does mean that
63+
`iceberg.control.group-id` cannot be shared between multiple connectors.
64+
6065
## Kafka configuration
6166

6267
By default the connector will attempt to use Kafka client config from the worker properties for connecting to

0 commit comments

Comments
 (0)