启用kafka源连接器幂等性



如何启用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

设置这些配置后,我可以在哪里看到我的连接工作器应用的配置

在日志中,当任务开始时应该显示ProducerConfigConsumerConfig

相关内容

  • 没有找到相关文章

最新更新