Categories
Mastering Development

Spring-cloud kafka stream schema registry

I am trying to transform with functionnal programming (and spring cloud stream) an input AVRO message from an input topic, and publish a new message on an output topic. Here is my transform function : @Bean public Function<KStream<String, Data>, KStream<String, Double>> evenNumberSquareProcessor() { return kStream -> kStream.transform(() -> new CustomProcessor(STORE_NAME), STORE_NAME); } The CustomProcessor is […]