создаю объект партишенера:
textLines.to(OUT_TOPIC, Produced.streamPartitioner(partitioner));
Я могу быть уверен, что каждый поток сделает копию этого партишенера?Или для этого нужно ещё что-то сделать?
Хочу избежать рейсов
А какие рейсы ты боишься?
Обсуждают сегодня