У меня проблема при получении сообщения от Kafka, если выдается исключение, то выполнение команды...

A Kafka Consumer по умолчанию периодически фиксирует текущие смещения, если он не отключен путем...

Я пытаюсь подключить брокера Kafka с использованием "SASL_PLAINTEXT" или "PLAINTEXT" , но получаю...

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

Как документация функции GetMetaData: // GetMetadata queries broker for cluster and topic metadata....

Рассмотрим этот цикл событий: В то время как больше сообщений msg_in = consumer.Poll () msg_out =...

Я использую библиотеку C (librdkafka), чтобы написать потребителя Kafka. Мне нужно знать последнее...

Когда потребитель не получает сообщение в течение 5 минут (значение по умолчанию max.poll.interval

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

node-rdkafka требует Python 2.7 как одну из зависимостей, и она уже доступна в системе, для нее...

Я использую lib-rdkafka, так что мне нужно установить в модуль узла, к сожалению, я не могу...

Я использую библиотеку confluent-kafka-go внутри моего бинарного файла go, и эту библиотеку...

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

Я хочу обработать тему при запуске приложения, используя Confluent dotnet client .Предположим...

Я тестирую Apache Kafka Producer с нативной реализацией java против confluent-kafka Python, чтобы...

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