apache-kafka

10зной

1ответ

Storm-Kafka несколько носиков, как разделить нагрузку?

Я пытаюсь поделиться этой задачей между несколькими носиками. У меня есть ситуация, когда я получаю один кортеж/сообщение за раз из внешнего источника, и я хочу иметь несколько экземпляров носика, осн

9зной

1ответ

Kafka: Не могу создать несколько потоков Потребители

Я только что начал работать с бета-версией Kafka 0.8 1. У меня есть очень простой пример, и проблема в том, что я могу получить только один потребитель сообщения, а не несколько. То есть метод runSing

2зной

4ответ

Добавление метки времени в сообщении kafka message

Есть ли способ, которым я могу заголовок временной метки в сообщении Kafka message? Я хочу проверить, когда сообщение было создано на стороне потребителя, и на основе этого применить прикладную логику

4зной

1ответ

Kafka - производитель - ручка «не удалось отправить»

Я запускаю 0,8 Kafka и создаю продюсера, используя предоставленный Java API. Функции API для отправки сообщения (или сообщений) возвращают пустоту. Есть ли способ получить статус отправленного сообщен

0зной

1ответ

Apache Kafka - Потребитель не получает сообщения от производителя

Буду признателен за вашу помощь по этому вопросу. Я строю потребитель Apache Kafka, чтобы подписаться на другой уже запущенный Kafka. Теперь моя проблема заключается в том, что, когда мой продюсер тол