让我来描述一下。。我们使用的是kafka版本1.1.1,并且有一个kafka流应用程序。这个应用程序有6个示例,它们使用125个分区的主题。每个使用者示例有21个使用者线程。
我们发现以下命令有问题: kafka-consumer-groups.sh --bootstrap-server $BROKERS --group group_to_describe --describe
当我们将一个示例联机并将其加入使用者组时,上面的命令可以完美地工作。然而,此后我们看到了不一致的结果。例如,如果我们使另外两个示例联机,然后发出上述命令,则会出现以下错误: Error: Executing consumer group command failed due to null
这是不一致的,因为我们可以有3或4个使用者示例成功地加入到组中,并且该命令将起作用,而其他时候我们最多只能加入2个。
使用者示例似乎仍在处理数据,但是我们无法描述组并查看延迟、分配的分区、组中的使用者等。
有人知道问题出在哪里吗?
暂无答案!
目前还没有任何答案,快来回答吧!