如何从卡夫卡连接器获得卡夫卡引导配置设置

任何人知道如何无论是从SinkConnector或SinkTask得到工人的配置设置“bootstrap.servers”？或者如何从连接器获取Kafka集群信息？

谢谢

AFAIK，Connect API现在不提供此信息。如果您需要此功能，或许您最好的选择是在Apache Kafka项目上打开JIRA并解释用例（即您计划如何执行此信息）。

2017-03-04 01:51:44

谢谢，格温，您的回复。用例很简单，可以将一些消息重定向到错误主题。目前我的解决方法是为生产者设置附加设置，将一些消息转发给错误主题（例如发生SQL错误时）。 –

啊，明白了！我们正在将错误处理权限构建到框架中，所以您不需要在连接器中执行它。 –

太棒了！有这个功能会很棒。 –

回答