kafka-consumer-api

2зной

1ответ

Кафка Consumer Error - хххй имя_узел ни servname при условии, или не известен

При запуске консоли потребителя, используя следующую команду $ ~/проект/ЛИЭС/kafka_2.9.2-0.8.1.1/бен/kafka- console-consumer.sh --zookeeper локальный: 2181 --topic customerevents --autocommit.interval

1зной

1ответ

Storm Kafka Spout не фиксирует смещение в локальном кластере, носик получает одно и то же сообщение повторно

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

0зной

1ответ

MetaData Response - имя хоста брокера неверно

Я использую SimpleConsumer python-kafka для прослушивания темы в брокерах kafka. Брокер Kafka работает на машине с именем хоста BROKER_HOST. Теперь SimpleConsumer запросы на тему метаданных от брокера

2зной

1ответ

Kafka установил максимальное количество сообщений для чтения из темы

Я новичок в Apache Kafka и изучаю SimpleConsumer для чтения сообщений из этой темы. Я использую следующий фрагмент кода, чтобы сделать то же самое, FetchRequestBuilder builder = new FetchRequestBuilde

15зной

6ответ

Как читать данные с использованием Kafka Consumer API с самого начала?

Пожалуйста, кто-нибудь скажет мне, как читать сообщения с использованием API-интерфейса Kafka с самого начала каждый раз, когда я запускаю потребительскую банку.