Invoking Kafka Producer Interceptor and Logs

Question

We are using Confluent JDBC Connector to ingest data to Kafka.

We have setup CustomInterceptor by setting following property:

producer.interceptor.classes=CustomInterceptor

in

connect-*.properties

But it does not seem to get invoked.

Another problem is that we are not able to see INFO logs which we are adding to our CustomInterceptor.

We are looking into following logs:

confluent log connect

confluent log kafka

In this case,

1. Is there anything else we need to set up as property to get the CustomInterceptor working ?

2. Where do we see the logs from CustomInterceptor ?

Thanks in advance,

Answer 1

It's working now. Earlier i think one of the confluent components was not getting started correctly and hence the failure.