Как указать serdes в кггруппированном потоке в потоках kafka 2

Question

Когда я обновляю до потоков Кафки 2.1, он говорит, что Serialized устарел.Как явно указать serdes с использованием groupedstream в версии Kafkastream 2.1.

KGroupedStream<Integer, Long> groupedStream = msg.groupByKey(Serialized.with(Serdes.Integer(), Serdes.Long()));

Answer 1

Как указывают JavaDocs:

@ устарело с версии 2.1. Используйте {@link org.apache.kafka.streams.kstream.Grouped)} вместо