要绝对清楚，您的接收器上需要拦截器和源.如果不这样做，您将无法使用 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.