我们有一个（合流）托管的kafka安装，有5个代理和2个连接器主机。我有两个主题，从来没有得到任何消费者分配给他们，尽管反复启动和停止的连接器，这是应该听他们。这个配置直到最近才运行（不，没有任何变化-我们已经做了一个审计来确认）。如果有的话，我能做些什么来强制消费者分配这些主题？
hwazgwia1#
出现此问题的原因有两个：（1）我错误地安装了postgresql和sqlserverjdbc连接器的新版本{与已安装的版本冲突}，以及（2）不理解源连接器没有为其分配使用者组。另外一个重要的信息（感谢confluent的支持团队）是，通过阅读私人或隐藏的主题，你可以看到你的连接器在哪里 connect-offsets . 一旦你有了它，你可以检查你的实际数据库查询，看看它返回什么然后（如果必要）重置连接器的偏移量。
connect-offsets
1条答案
按热度按时间hwazgwia1#
出现此问题的原因有两个：（1）我错误地安装了postgresql和sqlserverjdbc连接器的新版本{与已安装的版本冲突}，以及（2）不理解源连接器没有为其分配使用者组。
另外一个重要的信息（感谢confluent的支持团队）是，通过阅读私人或隐藏的主题，你可以看到你的连接器在哪里
connect-offsets. 一旦你有了它，你可以检查你的实际数据库查询，看看它返回什么然后（如果必要）重置连接器的偏移量。