So, I have created a simple function which copies the message from input topic to output topic.
public class MirrorFunction implements Function<T, T> { @Override public T process(T input, Context ctx) { ... return input; } } The input topic message is stored in avro schema. However when I check the schema of the output topic it has not changed to json. How can I ensure that output topic schema is also maintained as avro. Thanks Sachin