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

问题描述

如何将Confluent Control Center拦截器添加到现有的S3(接收器)连接器?监视水槽.我正在寻找文件.感谢您的帮助.

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.

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