Hi,
1. You'd have to configure your Kafka connector source to use a
DeserializationSchema that deserializes the Kafka record byte to your
generated Avro type. You can use the shipped `AvroDeserializationSchema` for
that.
2. After your Kafka connector source, you can use a flatMap transformation
hi, i’am a new comer to learn flink stream. and i wanna try to split the
kafka avro field into multiple fields.
for example i have this one in my kafka topic :
{
id : 12345,
name : “john”,
location : “indonesia;jakarta;south jakarta”
}
and then i wanna split the location value by “;”
