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)
