调试模式下的kafka连接

v7pvogib  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(292)

我使用的是原生的ApacheKafka,而不是合流版的Kafka。
我正在使用kafka jdbc连接器插件。我打算设置一个断点并通过ide(intellij)进行检查。
如何使connect侦听调试端口并挂起。我提到了什么是一个简单,有效的方法来调试自定义Kafka连接器?但这是合流Kafka
我正在为apachekafka寻找下面的合流配置等价物

CONNECT_DEBUG=y; export DEBUG_SUSPEND_FLAG=y;
xytpbqjk

xytpbqjk1#

合流版Kafka
没有这种事。两者都是相同的apachekafka,所以脚本是相同的(这是 kafka-run-class )
你提到的 confluent cli命令,用于本地部署合流堆栈,只是重定向 CONNECT_DEBUG 进入 KAFKA_DEBUG 因此,它总是 KAFKA_DEBUG 对于所有的Kafka组件(包括zookeeper,令人惊讶的是)没有 CONNECT_DEBUG 专门用于连接。

相关问题