汇流控制中心拦截器

Question

如何将Confluent Control Center Interceptor添加到现有S3（Sink）连接器？监视接收器。我正在寻找文件。任何帮助表示赞赏。

Answer 1

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

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

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

如果您在分布式模式下运行它，那么worker配置文件将是etc/kafka/connect-distributed.properties。