小编Avi*_*ale的帖子

我正在构建一个简单的应用程序,按顺序执行 -

1)从远程IBM MQ读取消息(遗留系统仅适用于IBM MQ)

2)将这些消息写入Kafka主题

3)从同一个Kafka主题中读取这些消息并调用REST API.

4)未来可能会有其他消费者阅读这个主题.

我开始知道Kafka有新的流API,在速度/简单性等方面应该比Kafka消费者更好.有人可以告诉我,如果流API非常适合我的用例以及在什么时候在我的过程中我可以插上吗？

假设一个3个分区的kafka主题被3个消费者组成的消费者组消费。在云环境中，如果有新的消费者扩大规模，现在该组中有4个消费者。在这种情况下会发生什么？

• Kafka是否创建另一个分区，以便新使用者可以访问它

要么

• 新消费者是否闲置并且不消费任何东西？