如何启用Kafka源连接器的幂等特性?
我知道在confluent中,我们可以通过工作配置中的producer.*
属性覆盖生产者配置,但是Kafka本身呢?是一样的吗?
设置这些配置后,我在哪里可以看到我的连接工作者应用的配置?
Confluent不会修改Kafka Connect的基本属性。
对于Kafka源任务使用的生产者和Kafka接收任务使用的消费者的配置,可以使用相同的参数,但需要以生产者为前缀。和消费者。分别为
从2.3.0开始,客户端配置覆盖可以通过使用前缀producer.override为每个连接器单独配置。和consumer.override。为Kafka源或Kafka sink分别设置
https://kafka.apache.org/documentation/connect_running
然而,Kafka Connect源不是恒等的- Kafka -7077 &kip - 308
设置这些配置后,我可以在哪里看到我的连接工作器应用的配置
在日志中,当任务开始时应该显示ProducerConfig
或ConsumerConfig