clear query| facets| time Search criteria: .   Results from 1 to 10 from 3133 (0.0s).
Loading phrases to help you
refine your search...
[expand - 1 more] - Streams SessionStore - bug or documentation error? - Kafka - [mail # user]
...Tom,I think there is a documentation error on the `findSessions` function,where the last parameter should really be "the start timestamp of thelatest session to search for".So back to your e...
   Author: Guozhang Wang , 2018-10-17, 15:31
[expand - 1 more] - Why is segment.ms=10m for repartition topics in KafkaStreams? - Kafka - [mail # user]
...Hi Niklas,By default, the retention.ms config is set to 7 days, and currently streamsdoes not try to override this value. What you observed, is probably becauseyour application is being rese...
   Author: Guozhang Wang , 2018-10-16, 15:31
[expand - 1 more] - Batch processing with Kafka Streams with at-least-once semantics - Kafka - [mail # user]
...I think we should not allow negative values, and today it seems that thisis not checked against.In fact, it should be a one-liner fix in the `config.define` function callto constraint its po...
   Author: Guozhang Wang , 2018-10-16, 15:19
[KAFKA-4587] Rethink Unification of Caching with Dedupping - Kafka - [issue]
...This is discussed in PR https://github.com/apache/kafka/pull/1588In order to support user-customizable state store suppliers in the DSL we did the following:1) Introduce a TupleForwarder to ...
http://issues.apache.org/jira/browse/KAFKA-4587    Author: Guozhang Wang , 2018-10-16, 00:55
[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
[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
[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