Hi all, I am trying to consume data from azure eventhub using the kafka ingress and i am getting the following error.
*java.lang.IllegalStateException: The io.statefun.kafka/ingress ingress requires a UTF-8 key set for each record.* While sending the data to the Event hub using my data producer, I am not sending it with any KEY. And the same data can be consumed without any issues with a normal flink application . I can see the error is raising from RoutableProtobufKafkaIngressDeserializer.requireNonNullKey()
