0

目前我有 3 个经纪人和一个有 1 个分区的主题

我的 Kafdrop 图像可以在下面看到

在此处输入图像描述

在此处输入图像描述

我正面临消费者抱怨的问题

Error: The client consumer subscribed to the topic (my-topic) whcih is not assigned to any partitions.

我认为消费者正在连接到不“控制”分区的代理。但是我不太了解 kafka 以及为什么消费者不会订阅正确的经纪人?

所以我的问题是:

1/分区少于broker数量是否正常

2/ 如果是,消费者是否应该面对我所面临的问题以及如何解决?

更新 1: 使用NEST.js 的消费者设置 在此处输入图像描述

streamClient.subscribeToResponseOf(...);
4

0 回答 0