Re: Stateful Function Ingress issues

2021-06-10 Thread Igal Shilman
Hello Jessy, Currently StateFun Kafka ingress interprets the keys of the record as the destination address. So you'd have to attach a key to use that specific ingress. If this is not an option for you, you can consider @Tim's suggestion or create a JIRA with a feature request, which we will be ha

Re: Stateful Function Ingress issues

2021-06-10 Thread Timothy Bess
Hi Jessy, I had this issue as well, here's the resolution . I ended up forking the version of statefun I used and removing the null check to default to empty string, but I'm goin

Re: Stateful Function Ingress issues

2021-06-10 Thread 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,

Stateful Function Ingress issues

2021-06-10 Thread 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,