Как отправить сообщение для производителя Кафки с помощью VertX eventbus

Question

Я учусь Кафка и VertX и я получил через следующие утверждения,

1.Kafka модуль позволяет получать события, опубликованные другим verticles Vert.x и отправить эти события для брокера Kafka.

2.Application посылает сообщения на модуль Кафки, используя VertX автобус

3.Kafka модуль действует в качестве продюсера

Любой давая мне знать, как они запрограммированы, было бы очень полезно. Благодарю.

Здесь я нашел исходный код, но я ищу более простой пример. https://github.com/zanox/mod-kafka

Answer 1

Этот модуль Kafka действует только как производитель, а не как потребитель. Поэтому намерение заключается в публикации сообщений внешних (исходящих) из системы. Пример ссылки на ссылку Github очень прост, если вы следуете вместе со следующим быстрым запуском Kafka в то же самое время - http://kafka.apache.org/081/documentation.html#quickstart

Вам не нужно использовать модули, вы можете использовать клиент Kafka Java в пределах ваши Verticles. Модули предназначены как механизм для повторного использования и обеспечения общей функциональности.

В Vertx 3.0 (следующая версия) система модулей удаляется в любом случае.