请多多包涵.我对卡夫卡很新.我正在研究生产者可以在运行时(不是固定数字)出现并发布消息的项目.目前,他们发布到kafka经纪人在运行时创建的唯一主题(topic.uuid),我在另一端订阅了一个订阅了topic.*模式并订阅了所有主题,并在新主题进入时进行了重新平衡.这是正确的方法吗？
现在,我很困惑,如果我们有一个主题有多个分区或多个主题,每个分区有一个分区.技术上,它是相同的.
但是,获得新分区(在运行时)和每个分区(在运行时)的新消费者所涉及的复杂性是什么,以实现更高的吞吐量,因为在各种博客中提到,分区数应该在组中具有相同数量的消费者.
apache-kafka ×1