CODEWITHSUNDEEP
apache-kafkakafka-consumer-apiapache-kafka-connectconfluent-platform
Pavan_Obj
Pavan_Obj

Reputation: 1129

Confluent Control Center Interceptor

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.

Upvotes: 0

Views: 1320

Answers (1)

Robin Moffatt
Robin Moffatt

Reputation: 32050

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.

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

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

Upvotes: 2

Related Questions