Hi We have a kafka consumer on flink that reads messages in avro and deserializes them to java objects. When we don't pass few values (for fields with default values) they are set as null which we then handle. However when I added a

rebalance

after the kafka consumer it started throwing null pointer exceptions. I think thats because the default values that come as null are serialized and deserialized again (not sure) and this time avro doesnt like it (since this time key exists but value is null) The real problem however is that I get this null pointer exception only in my local system whereas it works fine on EMR with real Kafka (MSK) Any idea why I am seeing this inconsistency?