在 Kafka Connector 中，如何获取我的 Kafka Connect 当前正在使用的 bootstrap-server 地址？
In Kafka Connector, how do I get the bootstrap-server address My Kafka Connect is currently using?
我正在自己开发 Kafka Sink 连接器。我的解串器是 JSONConverter。但是，当有人向我的连接器主题发送错误的 JSON 数据时，我想省略此记录并将此记录发送到我公司的特定主题。
我的困惑是：我找不到任何 API 来获取我的 Connect 的 bootstrap.servers。（我知道它在 confluent 的 etc 目录中，但硬写不是个好主意"connect-distributed.properties" 的目录代码以获取 bootstrap.servers)
那么问题来了，有没有其他方法可以让我在我的连接器程序中方便地获取 bootstrap.servers 的值？
与其尝试将 "bad" 记录从 SinkTask 发送到 Kafka，不如尝试使用 Kafka Connect 2.0 中添加的死信队列功能。
您可以将 Connect 运行时配置为自动将未能处理的记录转储到充当 DLQ 的已配置主题。
有关详细信息，请参阅添加此功能的KIP。
我正在自己开发 Kafka Sink 连接器。我的解串器是 JSONConverter。但是，当有人向我的连接器主题发送错误的 JSON 数据时，我想省略此记录并将此记录发送到我公司的特定主题。
我的困惑是：我找不到任何 API 来获取我的 Connect 的 bootstrap.servers。（我知道它在 confluent 的 etc 目录中，但硬写不是个好主意"connect-distributed.properties" 的目录代码以获取 bootstrap.servers)
那么问题来了，有没有其他方法可以让我在我的连接器程序中方便地获取 bootstrap.servers 的值？
与其尝试将 "bad" 记录从 SinkTask 发送到 Kafka，不如尝试使用 Kafka Connect 2.0 中添加的死信队列功能。
您可以将 Connect 运行时配置为自动将未能处理的记录转储到充当 DLQ 的已配置主题。
有关详细信息，请参阅添加此功能的KIP。