我使用的是原生的ApacheKafka,而不是合流版的Kafka。
我正在使用kafka jdbc连接器插件。我打算设置一个断点并通过ide(intellij)进行检查。
如何使connect侦听调试端口并挂起。我提到了什么是一个简单,有效的方法来调试自定义Kafka连接器?但这是合流Kafka
我正在为apachekafka寻找下面的合流配置等价物
CONNECT_DEBUG=y; export DEBUG_SUSPEND_FLAG=y;
我使用的是原生的ApacheKafka,而不是合流版的Kafka。
我正在使用kafka jdbc连接器插件。我打算设置一个断点并通过ide(intellij)进行检查。
如何使connect侦听调试端口并挂起。我提到了什么是一个简单,有效的方法来调试自定义Kafka连接器?但这是合流Kafka
我正在为apachekafka寻找下面的合流配置等价物
CONNECT_DEBUG=y; export DEBUG_SUSPEND_FLAG=y;
1条答案
按热度按时间xytpbqjk1#
合流版Kafka
没有这种事。两者都是相同的apachekafka,所以脚本是相同的(这是
kafka-run-class
)你提到的
confluent
cli命令,用于本地部署合流堆栈,只是重定向CONNECT_DEBUG
进入KAFKA_DEBUG
因此,它总是KAFKA_DEBUG
对于所有的Kafka组件(包括zookeeper,令人惊讶的是)没有CONNECT_DEBUG
专门用于连接。