Я работаю с Kafka Consumer и замечаю, что он потребляет сообщения, которые должны были быть...

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

Представьте, что у меня есть кластер из трех узлов kafka, в котором есть 1000 тем с одним разделом....

Я создал потребительское приложение для темы Kafka, используя библиотеку confluent.kafka и c #. Мне...

Я настроил несколько потребителей Kafka с помощью Spring Kafka, которые работают нормально. Однако,...

Сообщения Kafka, которые были отправлены производителем, продолжают показываться конечным...

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

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

Все брокеры в кластере могут нормально запускаться и работать, но иногда один из брокеров...

Я построил потребителя, используя Kafka Consumer API, способ, которым этот потребитель должен...

Я пытаюсь создать простую демонстрацию, используя Kafka с Go, но получаю эту ошибку: [56] Kafka...

Скажем, у меня есть приложение, которое считывает пакет данных из KAFKA, оно использует ключи...

Я использую confluent-kafka-5.1.2 сервер.У меня есть kafka-node потребитель (autoCommit: true,...

Я использую Kafka Consumer API для построения потребителя. Структура сообщения сложная. Для...

У меня есть получатель, имеющий несколько обработчиков, и когда у потребителя есть прослушиватель...

Я читал, что kafka предоставляет клиентскую библиотеку-потребитель, которая позволяет...

Я пытаюсь получить сообщение от kafka на моем локальном компьютере (виртуальный рабочий стол...

Как зафиксировать транзакции Kafka и сохранить порядок транзакций? У меня есть транснациональная...

Я использую пакет confluent_kafka для работы с Kafka. Я создаю тему таким образом: from...

Я запустил службу обмена сообщениями Kafka, где брокер Kafka настроен в докере и находится на порту...

Я настраиваю новый кластер Kafka и для целей тестирования я создал тему с 1 разделом и 3 репликами....

У меня есть настройка kafka, которая включает экспортер jmx в prometheus.Я ищу показатель, который...

Я довольно новичок в Kafka и только начал работать с Python, так что извините за мои неправильные...

Что такое advertised.listeners .Как это поможет подключиться к брокеру Kafka, работающему на...

Я использую Spring-Cloud-Starter-Stream-Kafka - 1.3.3 и Spring-Cloud-Stream с Spring Boot для...