Kafka Connect在调试模式下



我使用的是原生的apache kafka,而不是confluent的kafka版本。

我正在使用 kafka jdbc 连接器插件。我打算放置一个断点并通过我的 IDE(智能(进行检查。

如何使连接侦听调试端口并挂起。我提到了调试自定义 Kafka 连接器的简单有效方法是什么?但那是为了融合卡夫卡

我正在寻找以下阿帕奇卡夫卡的融合配置等效项

CONNECT_DEBUG=y; export DEBUG_SUSPEND_FLAG=y;

卡夫卡的汇流版

没有这样的事情。两者都是相同的Apache Kafka,因此脚本相同(这是kafka-run-class

(您引用的confluentCLI 命令用于 Confluent 堆栈的本地部署,只是将CONNECT_DEBUG重定向到KAFKA_DEBUG

因此,它始终KAFKA_DEBUG所有 Kafka 组件(包括 Zookeeper,令人惊讶(,而不是专门针对 ConnectCONNECT_DEBUG

相关内容

  • 没有找到相关文章

最新更新