Я новенький в весенней кафке.У меня есть микросервис, который отправляет сообщение с ключом kafka,...

Когда я использую: bin/kafka-console-consumer.sh --consumer.config kafka.properties...

Один из потребителей кафки, который у нас есть, должен идентифицировать некоторые шаблоны в...

У меня есть брокер Kafka с одним узлом, работающий внутри модуля в среде kubernetes с одним узлом.Я...

Я настраиваю Kafka и попал в стену относительно одного потребителя, подписавшегося на несколько тем

Я прочитал документацию по безопасности Kafka здесь: https://kafka.apache

Я использую потребитель kafka в нашем приложении, интегрированном с Camel (Camel-Kafka).Мы...

У меня есть kafka KTable, который содержит идентификаторы пользователей.Я называю этот Ktable...

Попытка запустить тест производительности потребителя в версии Kafka 2.1.0.Команда, которую я...

Я создаю горизонтальный масштабируемый микросервис Perl без состояния и искал реализацию группы...

Я запускаю местного производителя kafka для создания сообщений и создал для него тему "test_topic"

Я просматривал эту статью , которая объясняет, как обеспечить обработку сообщения ровно один раз,...

У нас есть потребитель Camel Kafka (camel-kafka: 2.23.1), чтобы прочитать сообщение от Kafka

Я написал метод void для приемника kafka и попытался написать JUNIT, но он выдает ненужное...

Я пытаюсь прочитать последние 3 записи из темы "input_topic".Я использую только одного потребителя

Я использую Kafka-Node в своем приложении NodeJS для создания и получения сообщений.Я начинаю...

kafka-python 1.4.6 Python 3.7.3 debezium / kafka 0.9 Я использую kafka-python для настройки своей...

Мы работаем с библиотекой python-kafka и обновили кластер Kafka до версии 2.2 с 0.10.2. Мы получили...

Я использую "программный" способ потребления сообщений из темы Кафки, используя org.springframework

У меня есть требование, где мне нужно найти недавно вставленное сообщение из темы Кафки. Как мне...

Я выполнил определенное требование и хотел бы услышать мнение людей и, конечно, не изобретать...

предположим, у меня есть тема kafka, скажем, о 10 разделах, я понимаю, что в каждой группе...

Spring Kafka (2.2.2.RELEASE), при получении записей партиями мы видим проблему с...

У меня есть тема kafka с фактором репликации 3 и min.insync.replicas = 2, продюсер, который...

Мой потребитель Kafka опрашивает быстрее, чем я ожидал. Есть ли какой-нибудь конфиг, который я могу...