Hi,

I am newbie to Kafka streams.

Tried below example :

https://github.com/confluentinc/kafka-streams-examples/blob/4.0.x/src/main/java/io/confluent/examples/streams/interactivequeries/WordCountInteractiveQueriesExample.java

http://localhost:7070/state/instances

[
{
"host": "localhost",
"port": 7070,
"storeNames": [
"windowed-word-count",
"word-count"
]
},
{
"host": "localhost",
"port": 7071,
"storeNames": [
"windowed-word-count",
"word-count"
]
}
]



I was able to query for count of a given word :

http://localhost:7070/state/keyvalue/word-count/hello

{
"key": "hello",
"value": 444
}



http://localhost:7071/state/keyvalue/word-count/world

{
"key": "world",
"value": 906
}


But i am not able to replicate following part(highlighted) of advertised
behavior in the example :

* 5) Use your browser to hit the REST endpoint of the app instance you
started in step 3 to query
* the state managed by this application.  Note: If you are running
multiple app instances, you can
* query them arbitrarily -- if an app instance cannot satisfy a query
itself, it will fetch the
* results from the other instances.


For example , following gave 404 error
http://localhost:7070/state/keyvalue/word-count/world

HTTP ERROR: 404

Problem accessing /state/keyvalue/word-count/world. Reason:

    Not Found

Please let me know where my expectations are going wrong.
Please note that i have tried both 3.3.0-post & 4.0.0-post branches.

Thanks,
Giridhar.

Reply via email to