Hello all,
I am a very new to Kafka and build kafka with Intellij IDEA. After
execute what the website said
https://cwiki.apache.org/confluence/display/KAFKA/Developer+Setup#DeveloperSetup-IntellijSetup.
I still get the following error , say, can not find the package. I dont knwo
why, a
I am with Gouzhang here.
I think all the suggestions are far to short-sighted. Especially this
wired materialize(String) call is broken totally and people go nuts
about how this will look. + Implementing more and better joins, not this
wired one we got currently. Implementing an one to many jo
It seems that the picture broken. Attached is the adding one.
At 2017-06-24 19:39:29, "张明磊" wrote:
Hello all,
I am a very new to Kafka and build kafka with Intellij IDEA. After
execute what the website said
https://cwiki.apache.org/confluence/display/KAFKA/Developer+Setup#DeveloperSe
Hi,
I am trying to send messages (synchronous) to a kafka cluster (lets
call it A). I get 'Batch Expired Exception' very frequently.
Also the average time taken per send is very high around 5 seconds.
However for the same code when I send messages to a different kafka
cluster B (with same netwo
Hi all,
Another pattern I think is worth adding is a sliding-windowed message
reordering and de-duplicating processor.
The outline I have in mind is based on this (just the timestamp would
come from the record context - in this question the timestamp was in the
body of the message):
https: