[ https://issues.apache.org/jira/browse/KAFKA-7640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
hitesh gollahalli bachanna updated KAFKA-7640: ---------------------------------------------- Attachment: intital_data_host.jpeg rest_api_call_host.jpeg rest_redirect_host.jpeg > 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 > Priority: Major > Attachments: intital_data_host.jpeg, rest_api_call_host.jpeg, > rest_redirect_host.jpeg > > > 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)