Sachin - You can specify the schema of the output topic when you submit a
function.
Thanks,
Sijie
On Thu, Dec 3, 2020 at 8:33 AM Sachin Mittal <sjmit...@gmail.com> wrote:
> 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
>
>
