Description
If a KafkaStreams app is using Standby Tasks then StreamPartitionAssignor will add the standby partitions to the partitionsByHostState map for each host. This is incorrect as the partitionHostState map is used to resolve which host is hosting a particular store for a key.
The result is that doing metadata lookups for interactive queries can return an incorrect host
Attachments
Issue Links
- links to