Я использую потоковую передачу Kafka, и у меня есть сомнения.
Мой код:
final KStream<String, Entity> inStream = builder.stream(TOPIC);
inStream.map((key, entity) -> {
....
return new KeyValue<>(key, entity);
}).to(NEW_TOPIC);`
Значение объекта NEW_TOPIC присутствует в объекте сущности.Моя проблема заключается в том, как извлечь значение этой NEW_TOPIC из сущности в случае выполнения нескольких задач.
Мои проблемы сводятся к тому, что, если существует несколько задач, будет ли kafka-streaming обрабатывать входящиесообщение до конца (вызывая метод to (), чтобы отправить его обратно в новую тему kafka), а затем извлечь новое сообщение из входящей темы?Если это поведение, я могу сохранить это значение в локальной / конечной переменной, чтобы использовать его позже.Если это не так, то мне нужно использовать другой способ.