pulsar function changes the schema of output topic to JSON from AVRO

[Sachin Mittal]

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