1） 有谁能解释kafka消费者是如何知道分区和使用特定分区的数据的？。什么是消费群体？2） 我有3个分区，所有分区都存储了数据，例如（msg1、msg2、msg3和msg4）。msg1->分区2，msg2->分区3，msg3->分区1，msg4->分区4。那么我如何从消费者那里获得消息的顺序（msg）。
mgdq6dx11#
代理分区是在zookeeper中注册的，因此通过查询zk，消费者可以发现可用分区是什么。高级消费者会自动为您执行此操作。使用者组是一组使用者示例的公共标识符，它使一个或多个主题的消费并行化成为可能。并行使用某个主题的使用者数量可以小于或等于该主题的分区数量，并且分区将在具有相同使用者组id的使用者示例之间进行平衡。kafka保证在一个分区内而不是跨分区的有序消费，所以如果需要的话，它必须在消费端处理。
1条答案
按热度按时间mgdq6dx11#
代理分区是在zookeeper中注册的，因此通过查询zk，消费者可以发现可用分区是什么。高级消费者会自动为您执行此操作。
使用者组是一组使用者示例的公共标识符，它使一个或多个主题的消费并行化成为可能。并行使用某个主题的使用者数量可以小于或等于该主题的分区数量，并且分区将在具有相同使用者组id的使用者示例之间进行平衡。
kafka保证在一个分区内而不是跨分区的有序消费，所以如果需要的话，它必须在消费端处理。