Confluent 控制中心拦截器
Confluent Control Center Interceptor
如何将 Confluent Control Center 拦截器添加到现有的 S3（接收器）连接器？监控接收器。我正在寻找文档。感谢您的帮助。
为了绝对清楚，您的接收器需要拦截器和源。如果不这样做，您将无法像今天这样使用 Confluent Control Center 监控您的管道。
要在 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.
如何将 Confluent Control Center 拦截器添加到现有的 S3（接收器）连接器？监控接收器。我正在寻找文档。感谢您的帮助。
为了绝对清楚，您的接收器需要拦截器和源。如果不这样做，您将无法像今天这样使用 Confluent Control Center 监控您的管道。
要在 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.