调用 Kafka Producer 拦截器和日志

Question

我们正在使用 Confluent JDBC 连接器将数据摄取到 Kafka。

我们通过设置以下属性来设置 CustomInterceptor：

producer.interceptor.classes=CustomInterceptor

在

connect-*.properties

但它似乎没有被调用。

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

我们正在调查以下日志：

confluent log connect

confluent log kafka

在这种情况下，

1. 为了让 CustomInterceptor 正常工作，我们还需要设置什么属性吗？

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

提前致谢，

Answer 1

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