[ https://issues.apache.org/jira/browse/KAFKA-7640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16718018#comment-16718018 ]
hitesh gollahalli bachanna commented on KAFKA-7640: --------------------------------------------------- Hello [~vvcephei] The rest api return 200 status code, but no data 1. Client is on 2.0.0 version but the server is 1.1.1 2. We use Virtual IP (to load balance ) as the kafka broker address in client code. 3. I have 36 partitions in the topic, for which there are 36 consumer on different machines. 4. I have about 360 million messages on the topic. I see rebalance happening, because i see a bunch of `revoked at the beginning of consumer rebalance`. Things I see in the when DEBUG is enabled. Using older server API v7 to send FETCHUsing older server API v5 to send METADATA \{topics=[],allow_auto_topic_creation=false} Using older server API v1 to send HEARTBEAT Is there anything in particular I need to look for in the logs. > 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 > > 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)