Michael Noll created KAFKA-3324: ----------------------------------- Summary: NullPointerException in StreamPartitionAssignor (Kafka Streams) Key: KAFKA-3324 URL: https://issues.apache.org/jira/browse/KAFKA-3324 Project: Kafka Issue Type: Bug Components: kafka streams Affects Versions: 0.10.0.0 Reporter: Michael Noll
KAFKA-3311 changed {{streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamPartitionAssignor.java}}, which unfortunately triggers NPEs consistently at this line: {code} for (Map.Entry<String, Set<TaskId>> entry : internalSourceTopicToTaskIds.entrySet()) { {code} The naive bug fix -- a simple null check -- seems to resolve the problem. PR incoming. -- This message was sent by Atlassian JIRA (v6.3.4#6332)