Кафка нескольких потребителей из разных перегородок

Question

У меня 4 раздела и 4 потребителя (например, A, B, C, D).Как настроить, какой потребитель будет читать с какого раздела, используя группы потребителей.Я использую Kafka с загрузкой Spring.

Answer 1

По умолчанию kafka автоматически назначает разделы;если у вас есть 4 потребителя в одной группе, они в конечном итоге получат по одному разделу каждый.Существуют свойства для настройки kafka, поэтому он не будет выполнять выделение сразу, пока вы не откроете своих потребителей.

Вы также можете назначить разделы самостоятельно.

Использование

public ContainerProperties(TopicPartitionInitialOffset... topicPartitions)

если вы создаете контейнер самостоятельно, или

@KafkaListener(id = "baz", topicPartitions = @TopicPartition(topic = "${topic}",
            partitions = "${partition}"))

, если вы используете @KafkaListener.