如何從卡夫卡連接器獲得卡夫卡引導配置設置

任何人知道如何無論是從SinkConnector或SinkTask得到工人的配置設置「bootstrap.servers」？或者如何從連接器獲取Kafka集羣信息？

謝謝

AFAIK，Connect API現在不提供此信息。如果您需要此功能，或許您最好的選擇是在Apache Kafka項目上打開JIRA並解釋用例（即您計劃如何執行此信息）。

2017-03-04 01:51:44

謝謝，格溫，您的回覆。用例很簡單，可以將一些消息重定向到錯誤主題。目前我的解決方法是爲生產者設置附加設置，將一些消息轉發給錯誤主題（例如發生SQL錯誤時）。 –

啊，明白了！我們正在將錯誤處理權限構建到框架中，所以您不需要在連接器中執行它。 –

太棒了！有這個功能會很棒。 –

回答