Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Duplicate
-
None
-
None
Description
This is first reported by jeff.klukas@gmail.com.
Similarly as we handle null keys in KStream join and aggregations in KAFKA-3561 (https://github.com/apache/kafka/pull/1472), for KTable.groupBy operators we should also gracefully handle null keys by filter them out since they will not be participating in the aggregation.
Attachments
Issue Links
- duplicates
-
KAFKA-3817 KTableRepartitionMap should handle null inputs
- Resolved
- relates to
-
KAFKA-3836 RocksDBStore.get() should not pass nulls to Deserializers
- Resolved