在Kafka Connector中，如何获取My Kafka Connect当前使用的引导服务器地址？
我正在自己开发一个Kafka接收器连接器。我的反序列化程序是JSONConverter。然而，当有人将错误的JSON数据发送到我的连接器主题时，我希望省略此记录，并将此记录发送到我公司的特定主题。
我的困惑是：我找不到任何API让我得到我的连接的bootstrap.servers.（我知道它在融合的etc目录，但它不是一个好主意，编写硬代码的目录connect-distributed.properties获取bootstrap.servers）
所以问题是，有没有其他方法可以让我获得引导的价值。在我的连接器程序中方便地使用服务器？
共有1个答案
与其尝试将“坏”记录从SinkTask发送到Kafka，不如尝试使用Kafka Connect 2.0中添加的死信队列功能。
您可以将连接运行时配置为自动将无法处理的记录转储到作为DLQ的已配置主题。
有关详细信息，请参阅添加此功能的KIP。
-
如果只是偶尔查询一次，可以通过chaipip或者ip138查询，这里chaipip更加权威一些。
-
我使用从引导选择中检索当前选择的值，但它返回了第一个选择的值，即警报保持显示项目1，当项目1和项目2被选中时，即使项目2是最近的选中。 如何获取最近选择的值以及选择了多少个选项？
-
问题内容： 我在代码中的某个地方遇到了异常，但是可以在应用程序启动时安全地导入相同的模块。我很好奇，看看Python寻找要导入模块的路径，以便我能够追踪为什么会出现此问题。我找到了这个： 这是系统在尝试导入模块时查找的所有路径的列表吗？ 问题答案： python默认检查的路径位置可以通过check检查。
-
我试图实现当前位置地图应用程序，我正在加载地图碎片，但它需要纬度和经度值来定位地址...如何实现当前位置地图功能...提前感谢.. 这是我的地图片段。
-
问题内容： 我正在使用量角器和茉莉花测试网站。我想知道当前网址以验证测试。 我努力了 我以这种方式使用此功能 问题答案： 如果您只想检查当前URL，请使用： 但是，如果您需要等到URL匹配某个值，请参阅答案的下一部分。 这是一个基于“ 预期条件 ”作者提供的示例的工作代码： 用法：
-
问题内容： 我将WordPress安装移至Windows /IIS服务器上的新文件夹。我正在PHP中设置301重定向，但似乎无法正常工作。我的帖子网址具有以下格式： 我不知道如何获取URL 的一部分。 -每个人似乎都建议- 正在返回一个空字符串。刚回来。为什么会这样，我该如何解决？ 问题答案： 也许是因为您使用IIS， 是您想要的，基于您用来解释的URL。 对于Apache，您可以使用。