clear query| facets| time Search criteria: .   Results from 1 to 10 from 1593 (0.0s).
Loading phrases to help you
refine your search...
kafka client 1.1.0 broker compatibility - Kafka - [mail # user]
...If Logstash's internal client is 1.1.0, it is be compatible with Kafkabrokers 2.0.0.Note: Brokers are always backward compatible to older clients (yourcase). Additionally, since, 0.10.0.0 re...
   Author: Matthias J. Sax , 2018-10-22, 20:14
Kafka Streams "processed" definition - Kafka - [mail # user]
...Same reply as to your other email asking the same question:> A message is considered processed, if all state updates are done and all> output messages are written.> > Note, that ...
   Author: Matthias J. Sax , 2018-10-22, 19:08
[expand - 2 more] - Throwing away prefetched records optimisation. - Kafka - [mail # dev]
...It's spread out multiple classes...Good starting point is here:https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java...
   Author: Matthias J. Sax , 2018-10-21, 21:59
[KAFKA-7420] Global stores should be guarded as read-only for regular tasks - Kafka - [issue]
...Global stores should only be update by the global thread. Any other task, should only read from a global store. However, when getting a reference to a global store, all tasks have full read/...
http://issues.apache.org/jira/browse/KAFKA-7420    Author: Matthias J. Sax , 2018-10-21, 08:33
[KAFKA-7131] Update release script to generate announcement email text - Kafka - [issue]
...When a release is finalized, we send out an email to announce the release. Atm, we have a template in the wiki (https://cwiki.apache.org/confluence/display/KAFKA/Release+Process). However, t...
http://issues.apache.org/jira/browse/KAFKA-7131    Author: Matthias J. Sax , 2018-10-21, 03:47
[KAFKA-4325] Improve processing of late records for window operations - Kafka - [issue]
...Windows are kept until their retention time passed. If a late arriving record is processed that is older than any window kept, a new window is created containing this single late arriving re...
http://issues.apache.org/jira/browse/KAFKA-4325    Author: Matthias J. Sax , 2018-10-20, 20:00
Kafka commit interval - Kafka - [mail # user]
...There is not upper limit.And yes, you are right about rebalancing. This would be an issue andyes, you can use the rebalance listener to address it (it's the purposeof the rebalance listener ...
   Author: Matthias J. Sax , 2018-10-19, 18:25
Kafka Streams, when is considered processed? - Kafka - [mail # user]
...A message is considered processed, if all state updates are done and alloutput messages are written.Note, that this notion of "processed" is based on sub-topologies, butnot the full topology...
   Author: Matthias J. Sax , 2018-10-19, 18:23
[expand - 1 more] - [DISCUSS] KIP-307: Allow to define custom processor names with KStreams DSL - Kafka - [mail # dev]
...What is the status of this KIP?-MatthiasOn 7/19/18 5:17 PM, Guozhang Wang wrote:> Hello Florian,> > Sorry for being late... Found myself keep apologizing for late replies> these ...
   Author: Matthias J. Sax , 2018-10-19, 18:13
[expand - 1 more] - [DISCUSSION] KIP-300: Add Windowed KTable API in StreamsBuilder - Kafka - [mail # dev]
...Boyang,what is the status of this KIP?-MatthiasOn 6/17/18 9:21 PM, Guozhang Wang wrote:> Thanks for the KIP Boyang, I made a pass over the KIP and the PR and have> some comments:> &...
   Author: Matthias J. Sax , 2018-10-19, 18:11