汇合控制中心拦截器

Question

如何将融合控制中心拦截器添加到现有的 S3(接收器(连接器？监视接收器。我正在寻找文档。任何帮助，不胜感激。

Answer 1

为了绝对清楚，您需要在接收器和源上拦截器。如果不这样做，则无法使用 Confluent 控制中心监控管道。

要在 Kafka Connect 中启用拦截器，请添加到工作线程属性文件：

consumer.interceptor.classes=io.confluent.monitoring.clients.interceptor.MonitoringConsumerInterceptor
producer.interceptor.classes=io.confluent.monitoring.clients.interceptor.MonitoringProducerInterceptor

如果您在分布式模式下运行它，则工作线程配置文件将etc/kafka/connect-distributed.properties 。