Re: Kafka Streams Usage Patterns

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):

Help needed with Batch Expired exception

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

Re:Can not find package when build kafka

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

Re: [DISCUSS] Streams DSL/StateStore Refactoring

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

Can not find package when build kafka

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,