clear query| facets| time Search criteria: .   Results from 1 to 10 from 3352 (0.0s).
Loading phrases to help you
refine your search...
[KAFKA-8428] Cleanup LogValidator#validateMessagesAndAssignOffsetsCompressed to assume single record batch only - Kafka - [issue]
...Today, the client -> server record batching protocol works like this:1. With magic v2, we always require a single batch within compressed set. And inside the LogValidator#validateMessages...    Author: Guozhang Wang , 2019-05-25, 05:14
[expand - 1 more] - Stream application :: State transition from PARTITIONS_REVOKED to PARTITIONS_ASSIGNED continuously - Kafka - [mail # user]
...Hello Nayanjyoti,Regarding the KIP-328, on-disk buffer is indeed being implemented but ithas not been completed and unfortunately has to slip to the next release.Now about the "PARTITIONS_RE...
   Author: Guozhang Wang , 2019-05-24, 17:48
Streams configuration for a stream with long varied processing times - Kafka - [mail # user]
...Hi Raman,Since you are using `transformation` already which is a lower-level API inDSL, you can basically do arbitrary logic like threading pool to processthe records within your `process()`...
   Author: Guozhang Wang , 2019-05-24, 17:37
[expand - 1 more] - [DISCUSS] KIP-444: Augment Metrics for Kafka Streams - Kafka - [mail # dev]
...Hello Patrik,Since we are rolling out 2.3 and everyone is busy with the release now thisKIP does not have much discussion involved yet and will slip into the nextrelease cadence.This KIP its...
   Author: Guozhang Wang , 2019-05-23, 23:44
[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-05-23, 20:21
[KAFKA-8420] Graceful handling when consumer switches from subscribe to manual assign - Kafka - [issue]
...Today if a consumer switches between subscribe (and hence relies on group rebalance to get assignment) and manual assign, it may cause unnecessary rebalances. For example:1. consumer.subscri...    Author: Guozhang Wang , 2019-05-23, 20:17
[expand - 11 more] - [DISCUSS] KIP-429 : Smooth Auto-Scaling for Kafka Streams - Kafka - [mail # dev]
...Cool, will update the page.On Wed, May 22, 2019 at 9:38 PM Matthias J. Sax wrote:> SGTM.>> I think we should still document the behavior on the KIP and explain why> it's implemen...
   Author: Guozhang Wang , 2019-05-23, 04:49
[KAFKA-8389] Duplicated MockProcessorSupplier / MockProcessor in TopologyTestDriverTest - Kafka - [issue]
...We have stand-alone classes of MockProcessorSupplier / MockProcessor classes, yet we have those in TopologyTestDriverTest as well. We should consider removing them....    Author: Guozhang Wang , 2019-05-22, 22:50
[KAFKA-2939] Make AbstractConfig.logUnused() tunable for clients - Kafka - [issue]
...Today we always log unused configs in KafkaProducer / KafkaConsumer in their constructors, however for some cases like Kafka Streams that make use of these clients, other configs may be pass...    Author: Guozhang Wang , 2019-05-21, 21:23
[VOTE] KIP-429: Kafka Consumer Incremental Rebalance Protocol - Kafka - [mail # dev]
...Hello folks,I'd like to start the voting for KIP-429 now, details can be found here:
   Author: Guozhang Wang , 2019-05-21, 17:33