我们正在使用汇合jdbc连接器将数据摄取到kafka。
我们已通过设置以下属性设置custominterceptor:
producer.interceptor.classes=CustomInterceptor
在里面
connect-*.properties
但它似乎没有被调用。
另一个问题是我们无法看到添加到custominterceptor的信息日志。
我们正在查看以下日志:
confluent log connect
confluent log kafka
在这种情况下,
为了让custominterceptor正常工作,我们还需要设置其他属性吗?
我们在哪里可以看到custominterceptor的日志?
提前谢谢,
1条答案
按热度按时间woobm2wo1#
它现在起作用了。早些时候,我认为其中一个汇合组件没有正确启动,因此失败了。