clear query| facets| time Search criteria: .   Results from 1 to 10 from 3053 (0.0s).
Loading phrases to help you
refine your search...
[KAFKA-6535] Set default retention ms for Streams repartition topics to Long.MAX_VALUE - Kafka - [issue]
...After KIP-220 / KIP-204, repartition topics in Streams are transient, so it is better to set its default retention to infinity to allow any records be pushed to it with old timestamps (think...
http://issues.apache.org/jira/browse/KAFKA-6535    Author: Guozhang Wang , 2018-10-15, 10:13
[KAFKA-7502] Cleanup KTable materialization logic in a single place - Kafka - [issue]
...Today since we pre-create all the `KTableXXX` operator along with the logical node, we are effectively duplicating the logic to determine whether the resulted KTable should be materialized. ...
http://issues.apache.org/jira/browse/KAFKA-7502    Author: Guozhang Wang , 2018-10-13, 00:21
Batch processing with Kafka Streams with at-least-once semantics - Kafka - [mail # user]
...Hello Tomoyuki,1. Seems a good use case for Streams.2. You should actually set it to Long.MAX_VALUE to indicate "not commitregularly by intervals", setting to "0" will actually mean to commi...
   Author: Guozhang Wang , 2018-10-12, 16:48
[ANNOUNCE] New Committer: Manikumar Reddy - Kafka - [mail # user]
...Congratulations Manikumar !GuozhangOn Thu, Oct 11, 2018 at 10:39 AM, Jason Gustafson wrote:> Hi all,>> The PMC for Apache Kafka has invited Manikumar Reddy as a committer and we>...
   Author: Guozhang Wang , 2018-10-11, 17:56
[KAFKA-6036] Enable logical materialization to physical materialization - Kafka - [issue]
...Today whenever users specify a queryable store name for KTable, we would always add a physical state store in the translated processor topology.For some scenarios, we should consider not phy...
http://issues.apache.org/jira/browse/KAFKA-6036    Author: Guozhang Wang , 2018-10-11, 02:02
[KAFKA-7243] Add unit integration tests to validate metrics in Kafka Streams - Kafka - [issue]
...We should add an integration test for Kafka Streams, that validates:1. After streams application are started, all metrics from different levels (thread, task, processor, store, cache) are co...
http://issues.apache.org/jira/browse/KAFKA-7243    Author: Guozhang Wang , 2018-10-10, 14:57
Why is segment.ms=10m for repartition topics in KafkaStreams? - Kafka - [mail # user]
...Hi Niklas,Default value of segment.ms is set to 10min as part of this project(introduced in Kafka 1.1.0):https://jira.apache.org/jira/browse/KAFKA-6150https://cwiki.apache.org/confluence/dis...
   Author: Guozhang Wang , 2018-10-09, 18:47
[expand - 1 more] - [DISCUSS] KIP-378: Enable Dependency Injection for Kafka Streams handlers - Kafka - [mail # dev]
...John, thanks for the explanation, now it makes much more sense to me.As for the concrete approach, to me it seems the first option requires lesschanges than the second (ConfiguredStreamsFact...
   Author: Guozhang Wang , 2018-10-09, 00:55
[KAFKA-6989] Support Async Processing in Streams - Kafka - [issue]
...Today Kafka Streams use a single-thread per task architecture to achieve embarrassing parallelism and good isolation. However there are a couple scenarios where async processing may be prefe...
http://issues.apache.org/jira/browse/KAFKA-6989    Author: Guozhang Wang , 2018-10-08, 18:18
[EXTERNAL] Incremental Cooperative Rebalancing - Kafka - [mail # dev]
...Hello Konstantine,Thanks for the great write-up! Here are a few quick comments I have aboutthe proposals:1. For "Kubernetes process death" and "Rolling bounce" case, there isanother parallel...
   Author: Guozhang Wang , 2018-10-05, 19:00