要完全清楚，您需要在接收器 和源上使用拦截器.否则，您将无法使用目前的Confluent Control Center监视管道.

To be absolutely clear, you need interceptors on your sink and source. If you don't, you can't monitor your pipelines with Confluent Control Center as it stands today.

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

To enable interceptors in Kafka Connect, add to the worker properties file:

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

如果以分布式模式运行它，则工作程序配置文件将为etc/kafka/connect-distributed.properties.

If you're running it in distributed mode then the worker config file will be etc/kafka/connect-distributed.properties.