Есть ли способ отправить данные в определенный раздел темы

Question

Как отправить данные в kstream на конкретный раздел темы?

Например, для темы A section2

Я пытался mysteam.to("topic"); Но это не сработало

Answer 1

Вы можете передать свой собственный разделитель в KStream.to() с помощью Produced.

См. https://kafka.apache.org/23/javadoc/org/apache/kafka/streams/kstream/KStream.html#to-java.lang.String-org.apache.kafka.streams.kstream.Produced-

https://kafka.apache.org/23/javadoc/org/apache/kafka/streams/kstream/Produced.html

Примеры реализации Partitioner интерфейс можно найти здесь:

• DefaultPartitioner
• RoundRobinPartitioner
• UniformStickyPartitioner