clear query| facets| time Search criteria: .   Results from 11 to 20 from 2066 (0.0s).
Loading phrases to help you
refine your search...
[KAFKA-8880] Augment Consumer.committed(partition) to allow multiple partitions - Kafka - [issue]
...We've observed that many usage of the consumer.committed calls are made for not only one partition, but for a batch of partitions. On the other hand, the OffsetFetchRequest protocol actually...    Author: Guozhang Wang , 2019-09-10, 00:03
[expand - 2 more] - [VOTE] KIP-447: Producer scalability for exactly once semantics - Kafka - [mail # dev]
...On Fri, Sep 6, 2019 at 6:33 PM Boyang Chen wrote:> Thanks Guozhang, I have polished the design doc to make it sync with> current KIP. As for overriding default timeout values, I guess ...
   Author: Guozhang Wang , 2019-09-09, 20:49
[KAFKA-8421] Allow consumer.poll() to return data in the middle of rebalance - Kafka - [issue]
...With KIP-429 in place, today when a consumer is about to send join-group request its owned partitions may not be empty, meaning that some of its fetched data can still be returned. Neverthel...    Author: Guozhang Wang , 2019-09-07, 05:16
[KAFKA-6460] Add mocks for state stores used in Streams unit testing - Kafka - [issue]
...We'd like to use mocks for different types of state stores: kv, window, session that can be used to record the number of expected put / get calls used in the DSL operator unit testing. This ...    Author: Guozhang Wang , 2019-09-05, 23:00
[VOTE] KIP-441: Smooth Scaling Out for Kafka Streams - Kafka - [mail # dev]
...+1 (binding).On Thu, Sep 5, 2019 at 2:47 PM John Roesler  wrote:> Hello, all,>> After a great discussion, I'd like to open voting on KIP-441,> to avoid long restore times in...
   Author: Guozhang Wang , 2019-09-05, 22:32
[expand - 15 more] - [DISCUSS] KIP-444: Augment Metrics for Kafka Streams - Kafka - [mail # dev]
...Hello Bruno,I think your concern makes sense, let's adopt this suggestion in KIP-444instead. Just to clarify:1. The default value would be "latest".2. The only other valid value is "0.10.0-2...
   Author: Guozhang Wang , 2019-09-05, 20:57
[expand - 1 more] - [VOTE] KIP-444: Refactor and Augment Metrics for Kafka Streams - Kafka - [mail # dev]
...+1 from myself.I'm now officially closing this voting thread with the following tally:binding +1: 3 (Guozhang, Bill, Matthias voted on the DISCUSS thread).non-binding +1: 2 (Bruno, John).Guo...
   Author: Guozhang Wang , 2019-09-05, 18:48
[expand - 10 more] - [DISCUSS] KIP-441: Smooth Scaling Out for Kafka Streams - Kafka - [mail # dev]
...Hello John,What I was thinking is that for other hosts of non-logged store only tasks,they will be ranked with a lag of "1" (as I tried to illustrate with"StatefulTasksToRankedCandidates[tas...
   Author: Guozhang Wang , 2019-09-05, 16:27
[KAFKA-8729] Augment ProduceResponse error messaging for specific culprit records - Kafka - [issue]
...1. We should replace the misleading CORRUPT_RECORD error code with a new INVALID_RECORD.2. We should augment the ProduceResponse with customizable error message and indicators of culprit rec...    Author: Guozhang Wang , 2019-09-04, 19:46
[expand - 1 more] - [VOTE] KIP-401: TransformerSupplier/ProcessorSupplier StateStore connecting - Kafka - [mail # dev]
...Hi Paul, thanks for the confirmation!Since we have three binding votes now I think you can proceed and mark itas accepted.On Tue, Sep 3, 2019 at 3:17 PM Paul Whalen  wrote:> Yeah, ag...
   Author: Guozhang Wang , 2019-09-03, 23:16