Apache Kafka. Пишем простой producer и consumer и тестируем их

[drew_dru]

Статья не будет полной без упоминания обновления Kafka KIP-500 (“Replace ZooKeeper with a Metadata Quorum,”), что в релизе с апреля 2021. Где рекомендуется использовать Kafka Raft Mode вместо ZooKeeper.

[MiSta1984]

Спасибо за комментарий.

[Ingvar_HrabroV]

Пройдемся по этапах создания продюсера

Добрый день, нашел опечатку. Спасибо за статью

[MiSta1984]

Спасибо за комментарий.

[gl-ko]

Партиции - это копии очередей наших сообщений. Количество партиций задается replication factor.

Простите, немного выпал на этом моменте. Почему вы приравниваете partition count и replication factor? Это немного разные вещи. Replication factor показывает, сколько копий одной партиции будет храниться на разных брокерах.

[MiSta1984]

Спасибо за комментарий. Да, согласен. Replication factor - показывает на сколько брокеров-последователей (follower) будут скопированы данные с ведущего лидера (leader), а partition count - количество патриций (разделов).

[Donquih0te]

Попробуйте spring-cloud-stream-kafka

Сильно упрощает работу с кафкой