例如,我有一个具有32个分区的主题,当我尝试使用“kafka console consumer.sh”监视该主题的消息时,我发现“kafka console consumer.sh”最多只占用32个分区中的18个分区。如何使“kafka console consumer.sh”使用来自给定主题的所有分区的消息?
通过查看其日志,我感觉“kafka console consumer.sh”只消耗了32个分区中的18个,如下所示:
例如,我有一个具有32个分区的主题,当我尝试使用“kafka console consumer.sh”监视该主题的消息时,我发现“kafka console consumer.sh”最多只占用32个分区中的18个分区。如何使“kafka console consumer.sh”使用来自给定主题的所有分区的消息?
通过查看其日志,我感觉“kafka console consumer.sh”只消耗了32个分区中的18个,如下所示:
暂无答案!
目前还没有任何答案,快来回答吧!