调用kafka生产者拦截器和日志

wb1gzix0  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(391)

我们正在使用汇合jdbc连接器将数据摄取到kafka。
我们已通过设置以下属性设置custominterceptor:

producer.interceptor.classes=CustomInterceptor

在里面

connect-*.properties

但它似乎没有被调用。
另一个问题是我们无法看到添加到custominterceptor的信息日志。
我们正在查看以下日志:

confluent log connect

confluent log kafka

在这种情况下,
为了让custominterceptor正常工作,我们还需要设置其他属性吗?
我们在哪里可以看到custominterceptor的日志?
提前谢谢,

woobm2wo

woobm2wo1#

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

相关问题