You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Giridhar Addepalli <gi...@gmail.com> on 2017/11/29 10:37:30 UTC
Kafka streams - regarding WordCountInteractiveQueriesExample
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.
Re: Kafka streams - regarding WordCountInteractiveQueriesExample
Posted by Bill Bejeck <bi...@confluent.io>.
Giridhar,
I can confirm, we'll get a patch for this soon.
Thanks for reporting.
-Bill
On Wed, Nov 29, 2017 at 8:21 AM, Bill Bejeck <bi...@confluent.io> wrote:
> Giridhar,
>
> Thanks for reporting this, I'll take a look.
>
> On Wed, Nov 29, 2017 at 5:37 AM, Giridhar Addepalli <
> giridhar1202@gmail.com> wrote:
>
>> 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.
>>
>
>
Re: Kafka streams - regarding WordCountInteractiveQueriesExample
Posted by Bill Bejeck <bi...@confluent.io>.
Giridhar,
Thanks for reporting this, I'll take a look.
On Wed, Nov 29, 2017 at 5:37 AM, Giridhar Addepalli <gi...@gmail.com>
wrote:
> 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.
>