KStream<String, String> left = builder.stream("source1"); left.toStream("soure2")
要在发送到source2之前序列化吗
rpppsulh1#
GenericRecord genericRecord2 = new GenericData.Record(schema);
使用genericord obj获取模式，然后将key、value放入`
genericRecord2.put(k, v);
完成put操作后，使用kstream api的.to（）方法将其写入主题
.to("topic",Produced.with(stringSerde, genericAvroSerde));`
确保在模式注册表中注册avro模式
1条答案
按热度按时间rpppsulh1#
使用genericord obj获取模式，然后将key、value放入`
完成put操作后，使用kstream api的.to（）方法将其写入主题
确保在模式注册表中注册avro模式