Как опубликовать сообщение в теме Kafka в Lagom

Недавно начала пользоваться лагомом. Пробую микросервис, где я получаю сообщение kafka и после некоторой обработки публикую другое сообщение в другой теме kafka. Основываясь на этой ссылке, я понимаю, что сообщение должно быть опубликовано по построенной теме - особенно эта часть примера кода, на которую я ссылаюсь.

final PubSubRef<Temperature> topic = pubSub.refFor(TopicId.of(Temperature.class, id));
      topic.publish(temperature);

Я не мог собрать Temperature DTO для POST из оставшегося клиента. Поэтому я создал свой DTO, который точно похож на HelloEvent — в моем случае это KafkaEvent.

Я пытался использовать код из здесь

Однако я не видел темы, созданной после выполнения операции POST. Я добавил операторы печати, и они появляются в консоли.

 System.out.println("Received id:" + id);
   final PubSubRef<KafkaEvent> topic = pubSub.refFor(TopicId.of(KafkaEvent.class, id));
   topic.publish(temperature);
   System.out.println("Sent to:" + topic.toString());

Я не вижу никаких ошибок в журнале сервера kafka или в моем проекте.

Есть ли какой-то шаг, который я пропустил? или я неправильно понимаю использование PubSubRegistry?

Пожалуйста, дайте мне знать, если потребуется дополнительная информация.

заранее спасибо

Навина


java apache-kafka lagom
person naveena kedlaya    schedule 16.09.2019    source источник

Ответы (1)


arrow_upward
1
arrow_downward

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

person Vladislav Kievski    schedule 17.09.2019