Skip to content

Commit 78b02e9

Browse files
authored
Merge pull request #3577 from amitkma/main
Fix typo in topics2TableMap to topic2TableMap in Kafka connect guide
2 parents 0d0f7d8 + d86bc07 commit 78b02e9

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

docs/integrations/data-ingestion/kafka/kafka-clickhouse-connect-sink.md

+2-2
Original file line numberDiff line numberDiff line change
@@ -348,7 +348,7 @@ or in the [Kafka documentation](https://kafka.apache.org/documentation/#consumer
348348

349349
#### Multiple high throughput topics {#multiple-high-throughput-topics}
350350

351-
If your connector is configured to subscribe to multiple topics, you're using `topics2TableMap` to map topics to tables, and you're experiencing a bottleneck at insertion resulting in consumer lag, consider creating one connector per topic instead. The main reason why this happens is that currently batches are inserted into every table [serially](https://github.com/ClickHouse/clickhouse-kafka-connect/blob/578ac07e8be1a920aaa3b26e49183595c3edd04b/src/main/java/com/clickhouse/kafka/connect/sink/ProxySinkTask.java#L95-L100).
351+
If your connector is configured to subscribe to multiple topics, you're using `topic2TableMap` to map topics to tables, and you're experiencing a bottleneck at insertion resulting in consumer lag, consider creating one connector per topic instead. The main reason why this happens is that currently batches are inserted into every table [serially](https://github.com/ClickHouse/clickhouse-kafka-connect/blob/578ac07e8be1a920aaa3b26e49183595c3edd04b/src/main/java/com/clickhouse/kafka/connect/sink/ProxySinkTask.java#L95-L100).
352352

353353
Creating one connector per topic is a workaround that ensures that you get the fastest possible insert rate.
354354

@@ -405,4 +405,4 @@ Kafka keys are not stored in the value field by default, but you can use the `Ke
405405
transforms=keyToValue
406406
transforms.keyToValue.type=com.clickhouse.kafka.connect.transforms.KeyToValue
407407
transforms.keyToValue.field=_key
408-
```
408+
```

0 commit comments

Comments
 (0)