[jira] [Created] (KAFKA-5510) Streams should commit all offsets regularly

Matthias J. Sax created KAFKA-5510: -- Summary: Streams should commit all offsets regularly Key: KAFKA-5510 URL: https://issues.apache.org/jira/browse/KAFKA-5510 Project: Kafka Issue Type:

[jira] [Reopened] (KAFKA-4262) Intermittent unit test failure ReassignPartitionsClusterTest.shouldExecuteThrottledReassignment

[ https://issues.apache.org/jira/browse/KAFKA-4262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4262: This happened again

Re: [DISCUSS] KIP-147: Add missing type parameters to StateStoreSupplier factories and KGroupedStream/Table methods

I think the discussion on Streams DSL refactoring will render this KIP obsolete. I'll leave is as under discussion until something is agreed and then move it to discarded. Cheers, Michał On 03/06/17 10:02, Michal Borowiecki wrote: I agree maintaining backwards-compatibility here adds a

Re: Re: [DISCUSS] KIP-165: Extend Interactive Queries for return latest update timestamp per key

Hi Jeyhun, Could the proposed KeyContext.keyTs() be made more descriptive? e.g. lastUpdated() or similar? So that users don't have to read the docs to know it isn't the creation timestamp for instance. Cheers, Michał On 04/06/17 01:24, Jeyhun Karimov wrote: Hi Matthias, Thanks for

Build failed in Jenkins: kafka-trunk-jdk8 #1759

See Changes: [ismael] KAFKA-5506; Fix NPE in OffsetFetchRequest.toString and logging -- [...truncated 4.26 MB...] kafka.integration.PrimitiveApiTest > testMultiProduce

[GitHub] kafka pull request #3427: KAFKA-5501 [WIP]: use async zookeeper apis everywh...

GitHub user onurkaraman opened a pull request: https://github.com/apache/kafka/pull/3427 KAFKA-5501 [WIP]: use async zookeeper apis everywhere Synchronous zookeeper writes means that we wait an entire round trip before doing the next write. With respect to the controller, these

Re: Kafka streams KStream and ktable join issue

I thought, we drop records with null key? No? -Matthias On 6/23/17 12:25 AM, Damian Guy wrote: > My guess is it is because the record doesn't have a key, i.e., the key is > null. We have a fix for this in 0.11, in that we will skip records with a > null key during restore. > > On Fri, 23 Jun

Re: [VOTE] KIP-161: streams deserialization exception handlers

+1 On 6/23/17 9:45 AM, Guozhang Wang wrote: > +1. > > On Fri, Jun 23, 2017 at 6:42 AM, Bill Bejeck wrote: > >> Thanks for the KIP! >> >> +1 >> >> -Bill >> >> On Fri, Jun 23, 2017 at 7:15 AM, Damian Guy wrote: >> >>> Thanks for the KIP Eno. >>> +1

Re: [VOTE] KIP-160: Augment KStream.print() to allow users pass in extra parameters in the printed string

+1 On 6/23/17 9:43 PM, Guozhang Wang wrote: > +1 > > On Fri, Jun 23, 2017 at 3:16 AM, Eno Thereska > wrote: > >> +1 thanks! >> >> Eno >>> On 23 Jun 2017, at 05:29, James Chain wrote: >>> >>> Hi all, >>> >>> I apply original idea on

Re: [DISCUSS] Streams DSL/StateStore Refactoring

Damian, thanks for starting this discussion. I am not a fan of the builder pattern. It's too clumsy to use IMHO an raised the entry level bar. I also think that mixing optional parameters with configs is a bad idea. Have not proposal for this atm but just wanted to mention it. Hope to find some

[jira] [Created] (KAFKA-5509) add gradle option for building tarball with test jars

Eno Thereska created KAFKA-5509: --- Summary: add gradle option for building tarball with test jars Key: KAFKA-5509 URL: https://issues.apache.org/jira/browse/KAFKA-5509 Project: Kafka Issue

[GitHub] kafka pull request #3420: KAFKA-5506: Fix NPE in OffsetFetchRequest.toString

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3420 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Resolved] (KAFKA-5487) Rolling upgrade test for streams

[ https://issues.apache.org/jira/browse/KAFKA-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-5487. --- Resolution: Fixed Fix Version/s: (was: 0.11.0.1) 0.11.1.0 Issue

[GitHub] kafka pull request #3411: KAFKA-5487: upgrade and downgrade streams app syst...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3411 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] kafka pull request #3424: MINOR: Typo in comments makes debug confusing

Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/3424 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature