我使用的是原生的apache kafka,而不是confluent的kafka版本。
我正在使用 kafka jdbc 连接器插件。我打算放置一个断点并通过我的 IDE(智能(进行检查。
如何使连接侦听调试端口并挂起。我提到了调试自定义 Kafka 连接器的简单有效方法是什么?但那是为了融合卡夫卡
我正在寻找以下阿帕奇卡夫卡的融合配置等效项
CONNECT_DEBUG=y; export DEBUG_SUSPEND_FLAG=y;
卡夫卡的汇流版
没有这样的事情。两者都是相同的Apache Kafka,因此脚本相同(这是kafka-run-class
(您引用的confluent
CLI 命令用于 Confluent 堆栈的本地部署,只是将CONNECT_DEBUG
重定向到KAFKA_DEBUG
因此,它始终KAFKA_DEBUG
所有 Kafka 组件(包括 Zookeeper,令人惊讶(,而不是专门针对 ConnectCONNECT_DEBUG
。