调用 Kafka Producer 拦截器和日志

Question

我们正在使用 Confluent JDBC Connector 将数据提取到 Kafka。

我们通过以下设置设置了 CustomInterceptor 属性:

producer.interceptor.classes=CustomInterceptor

在

connect-*.properties

但它似乎没有被调用。

另一个问题是我们无法看到我们正在添加到我们的 CustomInterceptor 中的 INFO 日志。

我们正在调查以下日志：

confluent log connect

confluent log kafka

在这种情况下，

1. 我们还需要设置什么 属性 才能让 CustomInterceptor 工作吗？

2. 我们在哪里可以看到来自 CustomInterceptor 的日志？

提前致谢，

Answer 1

现在可以了。早些时候，我认为其中一个融合组件没有正确启动，因此失败了。