🔹 Kafka: публикуем и читаем сообщения 🔹 Как отправлять (producer) и получать (consumer) сообщения в Kafka? 🔸 Kafka решает проблему надёжной передачи событий между сервисами: сообщения сохраняются в топиках (topic), их можно масштабировать, реплицировать и повторно читать — без потери при рестартах.
🔸 Producer отправляет сообщения в topic — это логическое имя канала. Практически нужно указать broker и topic; Kafka распределит данные по partition для параллелизма.
kafka-console-producer --broker-list localhost:9092 --topic my-topic kafka-console-consumer --bootstrap-server localhost:9092 --topic my-topic --from-beginning --group test-group
🔸 Consumer читает из topic; offset фиксирует позицию чтения, а consumer group позволяет нескольким инстансам делить партиции и обрабатывать поток параллельно.
📚 Попробуйте отправить строки в producer и смотреть, как consumer в группе получает и балансирует партиции.
➡️ Мы в Telegram - Сетке - ВК Буду рад вашей реакции здесь⬇️
В этом посте были ссылки, но мы их удалили по правилам Сетки
