[FLINK-21956] NPE in Kafka ingress when the key is missing

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: statefun-3.0.0, statefun-2.2.3
• Component/s: Stateful Functions
• Labels: pull-request-available
• Assignee: Igal Shilman
• Reporter: Igal Shilman
• Created: 24/Mar/21 16:31
• Updated: 07/Jun/21 09:43
• Resolved: 21/Apr/21 11:10

Description

Our Kafka ingress requires a utf8 key, but if this key is missing, we need to display a meaningful message.

Issue Links

• links to: GitHub Pull Request #238