kafka-consumer-api

4зной

3ответ

Как видно из названия, у меня есть код, завернутый в бесконечный цикл while(true), и все они полностью пойманы try и catch. Однако этот поток запускается в основном методе, однако после длительного за

1зной

1ответ

Потребитель Kafka не смог получить сериализованный объект?

Так что я хочу реализовать простое приложение, которое отправляет уведомление kafka производителю kafka consumer.So далеко я успешно отправил сообщение String производителю потребителю. Но когда я пыт

3зной

3ответ

Как получить подтверждение от брокера Kafka, если сообщение создано продюсером?

Я хотел бы получить ответ от брокера, когда я создаю сообщение. Я пробовал механизм CallBack (путем реализации CallBack), используемый в KafkaProducer.send, но он не работал и не вызывает метод onComp

1зной

1ответ

Потребление данных из очереди Kafka с использованием топологии Storm

Алгоритм считывает данные из очереди Kafka с использованием KafkaSpout. я столкнулся следующее исключение: Exception in thread "main" java.lang.IllegalStateException: Couldn't initialize the topology

0зной

1ответ

Установка Сторм построить Jar

Я разработал класс Java, который считывает данные из очереди Кафки и выводит его из ZkHosts zkHosts=new ZkHosts("localhost:2181"); String topic_name="test"; String consumer_group_id="storm"; String