Spring и Kafka: использование одной и той же привязки для Kafka Producer и Kafka Streams

Можно ли использовать одну и ту же привязку для создания сообщений через Kafka Producer и для отправки результатов потоковой обработки с помощью Kafka Streams?

Сейчас я разделил их следующим образом:

    @Output(TOPIC_X)
    MessageChannel xOutput();

    @Output(TOPIC_X_ONE)
    KStream<?,?> xOneOutput();

Когда первый используется производителем:

channels
.xOutput()
.send(MessageBuilder
      .withPayload(x)
      .setHeader(KafkaHeaders.MESSAGE_KEY, x.getId()).build());

И второй потоками кафки:

@StreamListener
@SendTo(TOPIC_X_ONE)
public KStream<?,?> process(@Input(INPUT_TOPIC) KStream<String,String> inputStream){
    //ommited for clarity
}

А в application.yml у меня есть:

spring.cloud.stream.bindings:
  topic-x:
    destination: mytopic
    producer:
      useNativeEncoding: true
  topic-x-one:
    destination: mytopic
    producer:
      useNativeEncoding: true

Действительно ли необходимо разделить их, если они оба имеют одно и то же место назначения и оба являются выходами?

Я не знаком с Весной. Но я уверен, что эта информация есть в документации...

Matthias J. Sax 15.04.2019 06:24
Пользовательский скаляр GraphQL
Пользовательский скаляр GraphQL
Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Приходилось ли вам сталкиваться с требованиями, в которых вас могли попросить поднять тревогу или выдать ошибку, когда метод Java занимает больше...
Версия Java на основе версии загрузки
Версия Java на основе версии загрузки
Если вы зайдете на официальный сайт Spring Boot , там представлен start.spring.io , который упрощает создание проектов Spring Boot, как показано ниже.
Документирование API с помощью Swagger на Springboot
Документирование API с помощью Swagger на Springboot
В предыдущей статье мы уже узнали, как создать Rest API с помощью Springboot и MySql .
1
1
99
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Да, это необходимо; привязки обрабатываются двумя разными реализациями связывателя и другим клиентом kafka.

Базовые целевые типы для этих привязок также различаются. Один использует MessageChannel для общения, а другой использует KStream. Таким образом, необходимо иметь эти две отдельные привязки.

sobychacko 16.04.2019 16:04

Другие вопросы по теме