Обрабатывает ли KStream по одному сообщению за раз? - PullRequest
Новая
       35

Обрабатывает ли KStream по одному сообщению за раз?

0 голосов
/ 27 декабря 2018

Я использую потоковую передачу 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), а затем извлечь новое сообщение из входящей темы?Если это поведение, я могу сохранить это значение в локальной / конечной переменной, чтобы использовать его позже.Если это не так, то мне нужно использовать другой способ.

...