kafka-consumer-api

-1зной

1ответ

Имеет ли решение KafkaConsumer API 0.9 решение ниже?

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

2зной

1ответ

ExecutorService Shutdown - Kafka

Я получаю сообщения от Kafka и обрабатываю их с помощью службы Executor, как показано ниже. Я не вызываю executorService.shutdown(). Иногда я вижу исключение heapSize, но не уверен, что это может быть

0зной

1ответ

Кафка Потребитель - Клиент Java

Я видел эту записку в Кафка потребительской документации - Поскольку существует несколько разделов это по-прежнему балансирует нагрузку в течение многих потребительских экземпляров. Обратите внимание,

0зной

1ответ

Потребление сообщений с использованием Kafka Consumer - Java

Я видел ниже код для использования сообщений от Kafka. Существует 1 тема с 20 разделами и 20 потоков создаются с помощью ExecutorService. Есть 20 потоков сообщений, каждый из которых считывается из 1

3зной

1ответ

Kafka Consumer - Java (0.9 API)

Я смотрел на создание потребителя Kafka с использованием версии 0.9 API. Пожалуйста, вы можете объяснить, что подразумевается под балансировкой потребителей? В чем разница между потребителем и координ

2зной

1ответ

Не печатайте предупреждения kafka-console-consumer

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