clear query| facets| time Search criteria: .   Results from 1 to 10 from 760 (0.0s).
Loading phrases to help you
refine your search...
[DISCUSS] KIP-378: Enable Dependency Injection for Kafka Streams handlers - Kafka - [mail # dev]
...Hi Wladimir,Of the two approaches in the KIP - i feel the second approach is cleaner.However, am i correct in assuming that you want to have the`ConfiguredStreamsFactory` as a ctor arg in `S...
   Author: Damian Guy , 2018-10-10, 13:52
[KAFKA-5054] ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized - Kafka - [issue]
...putIfAbsent and delete should be synchronized as they involve at least 2 operations on the underlying store and may result in inconsistent results if someone were to query via IQ...
http://issues.apache.org/jira/browse/KAFKA-5054    Author: Damian Guy , 2018-10-02, 14:01
[VOTE] KIP-302 - Enable Kafka clients to use all DNS resolved IP addresses - Kafka - [mail # dev]
...Thanks  +1 (binding)On Sun, 23 Sep 2018 at 23:43 Edoardo Comar  wrote:> bumping the thread as the KIP needs 2 more binding votes ... pretty please> ...> ------------------...
   Author: Damian Guy , 2018-09-24, 15:27
No referential transparency with transform() ? - Kafka - [mail # user]
...The return value from the `TransformSupplier` should always be a `newYourTransformer(..)` as there will be one for each task and they arepotentially processed on multiple threads.On Mon, 24 ...
   Author: Damian Guy , 2018-09-24, 15:17
[VOTE] KIP-372: Naming Repartition Topics for Joins and Grouping - Kafka - [mail # dev]
...+1 (binding)On Tue, 18 Sep 2018 at 16:33 Bill Bejeck  wrote:> All,>> In starting work on the PR for KIP-372, the Grouped interface needed some> method renaming to be more co...
   Author: Damian Guy , 2018-09-20, 11:30
[DISCUSS] KIP-358: Migrate Streams API to Duration instead of long ms times - Kafka - [mail # dev]
...Thanks +1 (binding)On Sun, 16 Sep 2018 at 19:37 Nikolay Izhikov  wrote:> Dear commiters,>> I got two binding +1 in [VOTE] thread for this KIP [1].> I still need one more.>...
   Author: Damian Guy , 2018-09-17, 14:59
[VOTE] KIP-366 - Make FunctionConversations private - Kafka - [mail # dev]
...+1 (binding)ThanksOn Fri, 14 Sep 2018 at 10:00 Joan Goyeau  wrote:> Ok so we have only one binding vote up to now. I guess we need at least 3> binding votes.>> Thanks>>...
   Author: Damian Guy , 2018-09-14, 14:56
[KAFKA-4609] KTable/KTable join followed by groupBy and aggregate/count can result in duplicated results - Kafka - [issue]
...When caching is enabled, KTable/KTable joins can result in duplicate values being emitted. This will occur if there were updates to the same key in both tables. Each table is flushed indepen...
http://issues.apache.org/jira/browse/KAFKA-4609    Author: Damian Guy , 2018-09-14, 14:52
[KAFKA-4650] Improve test coverage org.apache.kafka.streams.kstream.internals - Kafka - [issue]
...Lots of classes have little or no coverage at all, i.e., KTableAggregate.KTableAggregateValueGetterKTableKTableRightJoin.KTableKTableRightJoinValueGetterSupplierKStreamAggregate.KStreamAggre...
http://issues.apache.org/jira/browse/KAFKA-4650    Author: Damian Guy , 2018-09-05, 10:53
[VOTE] KIP-365: Materialized, Serialized, Joined, Consumed and Produced with implicit Serde - Kafka - [mail # dev]
...+1On Sun, 2 Sep 2018 at 15:20 Matthias J. Sax  wrote:> +1 (binding)>> On 9/1/18 2:40 PM, Guozhang Wang wrote:> > +1 (binding).> >> > On Mon, Aug 27, 2018 at 5...
   Author: Damian Guy , 2018-09-03, 16:00