如何将 Confluent Control Center Interceptor 添加到现有的 S3(Sink) 连接器？监视接收器。我正在寻找文档。任何帮助表示赞赏。
【问题讨论】：
标签： apache-kafka kafka-consumer-api apache-kafka-connect confluent-platform
明确地说，您需要在接收器和源上使用拦截器。如果您不这样做，您将无法像现在一样使用 Confluent Control Center 监控您的管道。
要在 Kafka Connect 中启用拦截器，请添加到 worker 属性文件：
consumer.interceptor.classes=io.confluent.monitoring.clients.interceptor.MonitoringConsumerInterceptor
producer.interceptor.classes=io.confluent.monitoring.clients.interceptor.MonitoringProducerInterceptor
如果您在分布式模式下运行它，那么工作器配置文件将为etc/kafka/connect-distributed.properties。
【讨论】：
<dependencies> ... <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>1.0.0-cp1</version> </dependency> <dependency> <groupId>io.confluent</groupId> <artifactId>monitoring-interceptors</artifactId> <version>4.0.0</version> </dependency> ... <dependencies>