Я использую Spring Boot 2.0.7 и Spring-Kafka для создания шаблона запроса / ответа.В основном...

Я новичок в Golang и Kafa, так что это может показаться глупым вопросом. После того, как мой...

Как проверить, доступен ли сервер Kafka или нет. Я попробовал ниже scala code -Producer API. val...

Мы используем spring-kafka для приема сообщений, которые должны быть перенаправлены во внешний...

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

Мы подписываемся на данные в реальном времени с сервера AMPS [CRANK UP THE AMPS] в качестве...

При проверке состояния реплики темы вместе с репликами Isync мы обнаружили необычное поведение....

ConsumerCoordinator входит в циклический цикл при повторной проверке перезапрошенного раздела. CC...

I am sending `List<Object>` from Kafka Producer to a topic. A consumer which listens to the...

по умолчанию server.properties на 0.10.1.1 Брокер не определяет log.message.format.version явно

У меня есть сценарий использования. Я хочу изначально настроить кластер Kafka при запуске. У меня...

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

Я запускаю node-rdkafka как приложение Node.js.Потребитель зависает до бесконечности, не вынимая...

Поэтому, когда наше приложение Scales-Up / Scales-Down перегруппировывается в Kafka Consumer Group....

Я использую Spring Cloud Stream версии 1.1.2 для создания / интеграции потребителя с микросервисом

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

Ситуация довольно проста - у меня есть два kafka слушателя из двух разных тем, одна из которых...

У нас есть коннектор Kafka Elastic Search для передачи данных в Elastic search (v 5.6.3 ). Я...

Я выполняю следующий запрос на ksql.но я хочу только последние 20 записей . SELECT MAX(ROWTIME)...

Просматривая код потребителя Camel Kafka, можно увидеть, что в KafkaFetchRecords есть следующий...

я получаю это исключение при использовании небольших пакетов от kafka и использовании commitAsync...

Потребитель должен проверять сообщения с интервалом в 10 минут, это ответное сообщение должно...

Я использую Python Language.У меня есть CSV-файл, мне нужно конвертировать в JSON и отправить в...

Я пытаюсь создать JDBC-коннектор для kafka с помощью команды curl.Пожалуйста, помогите мне...

С https://kafka.apache.org/11/documentation.html#consumerconfigs, запись для request.timeout.ms...