Как вывести данные формата avro на тему в kstreams

Question

KStream<String, String> left = builder.stream("source1");

left.toStream("soure2")

хотите сериализовать перед отправкой на source2

Answer 1

GenericRecord genericRecord2 = new GenericData.Record(schema);

Получите схему, используя GenericRecord obj, а затем поместите ключ, значение в `

genericRecord2.put(k, v);

и, как только вы закончите с операцией put, запишите ее в тему, используя метод .to ()the kstream api

.to("topic",Produced.with(stringSerde, genericAvroSerde));`

Обязательно зарегистрируйте схему avro в реестре схем