调试模式下的 Kafka Connect

【问题标题】：Kafka Connect in debug mode调试模式下的 Kafka Connect
【发布时间】：2019-02-19 01:02:52
【问题描述】：

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

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

如何使连接侦听调试端口并挂起。我提到了What is a simple, effective way to debug custom Kafka connectors?，但那是为了融合卡夫卡

我正在寻找以下 apache kafka 的融合配置等价物

CONNECT_DEBUG=y; export DEBUG_SUSPEND_FLAG=y;

【问题讨论】：

【解决方案1】：

confluent版的kafka

没有这样的事情。两者都是同一个Apache Kafka，所以脚本是一样的（即kafka-run-class）

您引用的confluent CLI 命令用于本地部署 Confluent 堆栈，只是将CONNECT_DEBUG 重定向到KAFKA_DEBUG

因此，对于所有 Kafka 组件（包括 Zookeeper，令人惊讶的是），它始终是 KAFKA_DEBUG，而不是专门用于 Connect 的 CONNECT_DEBUG。

【讨论】：