[jira] [Resolved] (KAFKA-3744) Message format needs to identify serializer

[ https://issues.apache.org/jira/browse/KAFKA-3744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-3744. Resolution: Won't Fix Closing this as "won't fix" since Kafka now supports message headers f

Re: [DISCUSS] KIP-262 Metadata should include the number of state stores for task

I didn't really get what "upgrade strategy" was at the time that Guozhang mentioned it, so I wrote the above dialogue from my first understanding. I changed it to "upgrade strategy must be provided". Currently, however, I do not have anything in mind to facilitate upgrading older Kafka brokers. If

Re: [DISCUSS] KIP-262 Metadata should include the number of state stores for task

Thanks a lot for this KIP. I am not sure what you mean by > which could potentially break older versions of Kafka brokers The metadata that is exchange, is not interpreted by the brokers. The problem with upgrading the metadata format affect only Kafka Streams instances. If we don't provide an

Re: [VOTE] KIP-261: Add Single Value Fetch in Window Stores

+1 (binding) On 2/24/18 12:25 PM, Bill Bejeck wrote: > Thanks for the KIP! > > +1 > > Bill > > On Sat, Feb 24, 2018 at 2:33 PM, Damian Guy wrote: > >> Thanks Guozhang! >> +1 >> >> On Sat, 24 Feb 2018 at 19:12 Ted Yu wrote: >> >>> +1 >>> >>> On Sat, Feb 24, 2018 at 11:10 AM, Guozhang Wang >

[jira] [Created] (KAFKA-6590) Consumer bytes-fetched and records-fetched are not aggregated correctly

Jason Gustafson created KAFKA-6590: -- Summary: Consumer bytes-fetched and records-fetched are not aggregated correctly Key: KAFKA-6590 URL: https://issues.apache.org/jira/browse/KAFKA-6590 Project: Ka

Build failed in Jenkins: kafka-0.10.2-jdk7 #203

See Changes: [jason] KAFKA-6371; Fix DelayedFetch toString (#4328) -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H27 (

Re: [VOTE] KIP-261: Add Single Value Fetch in Window Stores

Thanks for the KIP! +1 Bill On Sat, Feb 24, 2018 at 2:33 PM, Damian Guy wrote: > Thanks Guozhang! > +1 > > On Sat, 24 Feb 2018 at 19:12 Ted Yu wrote: > > > +1 > > > > On Sat, Feb 24, 2018 at 11:10 AM, Guozhang Wang > > wrote: > > > > > Hi all, > > > > > > I want to start voting on KIP-261 to

Re: [VOTE] KIP-261: Add Single Value Fetch in Window Stores

Thanks Guozhang! +1 On Sat, 24 Feb 2018 at 19:12 Ted Yu wrote: > +1 > > On Sat, Feb 24, 2018 at 11:10 AM, Guozhang Wang > wrote: > > > Hi all, > > > > I want to start voting on KIP-261 to add a new API for window stores in > > order to optimize our current windowed aggregation implementations i

Re: [VOTE] KIP-261: Add Single Value Fetch in Window Stores

+1 On Sat, Feb 24, 2018 at 11:10 AM, Guozhang Wang wrote: > Hi all, > > I want to start voting on KIP-261 to add a new API for window stores in > order to optimize our current windowed aggregation implementations inside > Streams DSL: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP- >

[DISCUSS] KIP-262 Metadata should include the number of state stores for task

Hi all, I would like to discuss a KIP I've submitted : https://cwiki.apache.org/confluence/display/KAFKA/KIP-262%3A+Metadata+should+include+number+of+state+stores+for+task Regards, Richard Yu

[VOTE] KIP-261: Add Single Value Fetch in Window Stores

Hi all, I want to start voting on KIP-261 to add a new API for window stores in order to optimize our current windowed aggregation implementations inside Streams DSL: https://cwiki.apache.org/confluence/display/KAFKA/KIP- 261%3A+Add+Single+Value+Fetch+in+Window+Stores Please cast your vote befo

Re: [VOTE] 1.1.0 RC0

+1 Ran test suite where (known flaky) testMetricsLeak failed - the other tests passed. On Sat, Feb 24, 2018 at 8:16 AM, Damian Guy wrote: > Hello Kafka users, developers and client-developers, > > This is the first candidate for release of Apache Kafka 1.1.0. > > This is minor version release

[VOTE] 1.1.0 RC0

Hello Kafka users, developers and client-developers, This is the first candidate for release of Apache Kafka 1.1.0. This is minor version release of Apache Kakfa. It Includes 29 new KIPs. Please see the release plan for more details: https://cwiki.apache.org/confluence/pages/viewpage.action?page

Re: [VOTE] 1.0.1 RC2

+1 (non-binding) ... I used the Scala 2.12 binaries and run my tests with producers / consumers. On Thu, Feb 22, 2018 at 1:06 AM, Ewen Cheslack-Postava wrote: > Hello Kafka users, developers and client-developers, > > This is the third candidate for release of Apache Kafka 1.0.1. > > This is a b