Damian Guy created KAFKA-4163: --------------------------------- Summary: NPE in StreamsMetadataState during re-balance operations Key: KAFKA-4163 URL: https://issues.apache.org/jira/browse/KAFKA-4163 Project: Kafka Issue Type: Bug Components: streams Affects Versions: 0.10.1.0 Reporter: Damian Guy Assignee: Damian Guy Fix For: 0.10.1.0
During rebalance operations it is possible that an NPE can be thrown on StreamsMetadataState operations. We should first check it the Cluster object is non-empty. If it is empty we should return StreamsMetadata.NOT_AVAILABLE. Also, we should tidy up InvalidStateStoreException messages in the store API to suggest that the store may have migrated to another instance -- This message was sent by Atlassian JIRA (v6.3.4#6332)