java - 如何在 kstreams 中将 avro 格式的数据生成到主题上

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 操作后，使用 kstream api 的 .to() 方法将其写入主题

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

确保在模式注册表中注册 avro 模式