Re: Stateful Function Ingress issues

[Jessy Ping]

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()

Why is this check important and how to resolve this for eventhubs.?

private byte[] requireNonNullKey(byte[] key) {
  if (key == null) {
    IngressType tpe =
ProtobufKafkaIngressTypes.ROUTABLE_PROTOBUF_KAFKA_INGRESS_TYPE;
    throw new IllegalStateException(
        "The "
            + tpe.namespace()
            + "/"
            + tpe.type()
            + " ingress requires a UTF-8 key set for each record.");
  }
  return key;
}

Thanks
Jessy
On Thu, 10 Jun 2021 at 20:13, Jessy Ping <tech.user.str...@gmail.com> wrote:

> 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()
>
>
>