Description
KAFKA-3311 changed streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamPartitionAssignor.java, which triggers NPEs consistently at this line:
for (Map.Entry<String, Set<TaskId>> entry : internalSourceTopicToTaskIds.entrySet()) {
The impact is significant unfortunately because any end-to-end Streams job that I have been running keeps failing currently because of this bug.
How to fix
The naive fix – a simple null check – seems to resolve the problem. PR incoming.
Attachments
Issue Links
- is related to
-
KAFKA-3311 Move co-partition checking to PartitionAssignor and auto-create internal topics
-
- Resolved
-