I guess, the console producer inserts the data as String -- and not as
"binary JSON". try so us a different serializer to insert data with
expected format for Streams.
-Matthias
On 3/22/17 2:50 PM, Shanthi Nellaiappan wrote:
> Thanks for the info.
> With "page2",{"user":"2", "page":"22", "timest
The quickest answer I can give you is trying a similar example [1], where
we provide a driver that generates the required input data for the page
view example.
-Michael
[1]
https://github.com/confluentinc/examples/blob/3.2.x/kafka-streams/src/main/java/io/confluent/examples/streams/PageViewRegi
Any example for the above would be appreciated. Thanks
On Wed, Mar 22, 2017 at 2:50 PM, Shanthi Nellaiappan
wrote:
> Thanks for the info.
> With "page2",{"user":"2", "page":"22", "timestamp":143527817} as input
> for streams-pageview-input an "2",{"region":"CA","timestamp":143527817}
>
Thanks for the info.
With "page2",{"user":"2", "page":"22", "timestamp":143527817} as input
for streams-pageview-input an
"2",{"region":"CA","timestamp":143527817} as input for
streams-userprofile-input, the following error is shown,
Exception in thread "StreamThread-1" java.lang.Illegal
Thanks Michael. I am trying that out. What would be best way to clear the
values entered for a given input topic. Due to typo, if incorrect values
are entered in a topic, it has to be cleared. Otherwise, the program keeps
failing at processing incorrect input value.
On Wed, Mar 22, 2017 at 12:27 P
IIRC the PageViewTypedDemo example requires input data where the
username/userId is captured in the keys of messages/records, and further
information in the values of those messages.
The problem you are running into is that, when you are writing your input
data via the console consumer, the record
I have started exploring kafka streaming API. I'm trying to run
PageViewTypedDemo program as it is without any changes locally on a
desktop. Current kafka version is 0.10.1.0.
With the following inputs from 2 different console,
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic
s
