выход, указанный потребителем kafka

Я читал это в документации kafka: у Kafka также есть потребитель командной строки, который будет выгружать сообщения на стандартный вывод.

bin / kafka-console-consumer.sh --zookeeper localhost: 2181 --topic test --from-begin

Интересно, если я хочу отправлять сообщения потребителя и отправлять их на другой вывод, какие параметры нужно добавить в приведенную выше команду. kafka-console-consumer не имеет опции --help, я не могу найти никаких параметров, опций для команды.

Спасибо


person Jin    schedule 13.05.2015    source источник


Ответы (1)


Потребитель по умолчанию может выводить только на консоль, если вы не хотите загружать и изменять код.

Очень легко написать простого потребителя и вывести его в другой формат или сделать с ним что-нибудь еще.

Пример кода приведен на странице https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example

person Superaghu    schedule 18.05.2015