hitesh gollahalli bachanna created KAFKA-7640:
-------------------------------------------------
Summary: Kafka stream interactive query not returning data when
state is backed by rocksdb
Key: KAFKA-7640
URL: https://issues.apache.org/jira/browse/KAFKA-7640
Project: Kafka
Issue Type: Bug
Components: streams
Affects Versions: 2.0.0
Reporter: hitesh gollahalli bachanna
I have a kafka stream app running with 36 different instance (one for each
partition). Each instance come up one after the other. And I am building rest
service on top of the state to access the data.
Here some code that I use:
{code:java}
StreamsMetadata metadata = streams.metadataForKey(store, key, serializer); -->
call this find ouy which host has the key
if (localSelf.host().equals(hostStoreInfo.getHost())) {
get the key from local store
}
else {
call the remote host using restTemplate
}{code}
The problem now is `metadata` object returned has a different host/ip but the
data is on a different node. I was able to see using some application logs I
printed. This happens every time I start my application.
The `allMetadata` method in `KafkaStreams` class says the value will be update
as when the partition get reassigned. But its not happening in this case.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
