Confluent 控制中心拦截器 [英] Confluent Control Center Interceptor

问题描述

如何将 Confluent Control Center Interceptor 添加到现有的 S3(Sink) Connector?监视接收器.我正在寻找文档.任何帮助表示赞赏.

How do I add Confluent Control Center Interceptor to an existing S3(Sink) Connector? To monitor the Sink. I am looking for documentation. Any help is appreciated.

推荐答案

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

这篇关于Confluent 控制中心拦截器的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！