Jenkins build is back to normal : kafka-2.0-jdk8 #54

See

Re: [VOTE] 1.1.1 RC1

Thank you for testing and voting the release! I noticed that the date for 1.1.1-rc1 is wrong. Please kindly test and vote by Tuesday, June 26, 12 pm PT. Thanks, Dong On Fri, Jun 22, 2018 at 10:09 AM, Dong Lin wrote: > Hello Kafka users, developers and client-developers, > > This is the second

[VOTE] 0.10.2.2 RC1

Hello Kafka users, developers and client-developers, This is the second candidate for release of Apache Kafka 0.10.2.2. Note, that RC0 was created before the upgrade to Gradle 4.8.1 and thus, we discarded it in favor of RC1 (without sending out a email for RC0). This is a bug fix release

Build failed in Jenkins: kafka-1.1-jdk7 #154

See Changes: [wangguoz] MINOR: bugfix streams total metrics (#5277) -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H30

Re: [Discuss] KIP-321: Add method to get TopicNameExtractor in TopologyDescription

Thanks for writing the KIP! I'm +1 on the proposed changes over all. One minor suggestion: we should also mention that the `Sink#toString` will also be updated, in a way that if `topic()` returns null, use the other call, etc. This is because although we do not explicitly state the following

Re: [DISCUSS] - KIP-314: KTable to GlobalKTable Bi-directional Join

Hello Adam, Please see my comments inline. On Thu, Jun 21, 2018 at 8:14 AM, Adam Bellemare wrote: > Hi Guozhang > > *Re: Questions* > *1)* I do not yet have a solution to this, but I also did not look that > closely at it when I begun this KIP. I admit that I was unaware of exactly > how the

Re: [DISCUSS] KIP-319: Replace segments with segmentSize in WindowBytesStoreSupplier

Thanks John. On Fri, Jun 22, 2018 at 5:05 PM, John Roesler wrote: > Thanks for the feedback, Bill and Guozhang, > > I've updated the KIP accordingly. > > Thanks, > -John > > On Fri, Jun 22, 2018 at 5:51 PM Guozhang Wang wrote: > > > Thanks for the KIP. I'm +1 on the proposal. One minor comment

Re: [DISCUSS] KIP-319: Replace segments with segmentSize in WindowBytesStoreSupplier

Thanks for the feedback, Bill and Guozhang, I've updated the KIP accordingly. Thanks, -John On Fri, Jun 22, 2018 at 5:51 PM Guozhang Wang wrote: > Thanks for the KIP. I'm +1 on the proposal. One minor comment on the wiki: > the `In Windows, we will:` section code snippet is empty. > > On Fri,

Re: [VOTE] 0.11.0.3 RC0

+1 (non-binding) Built from source and ran quickstart successfully on Ubuntu (with Java 8). Thanks Matthias! --Vahid From: "Matthias J. Sax" To: dev@kafka.apache.org, us...@kafka.apache.org, kafka-clie...@googlegroups.com Date: 06/22/2018 03:14 PM Subject:[VOTE] 0.11.0.3

Re: [VOTE] 2.0.0 RC0

+1 (non-binding) Built from source and ran quickstart successfully on Ubuntu (with Java 8 and Java 9). Thanks Rajini! --Vahid

Re: [DISCUSS] KIP-319: Replace segments with segmentSize in WindowBytesStoreSupplier

Thanks for the KIP. I'm +1 on the proposal. One minor comment on the wiki: the `In Windows, we will:` section code snippet is empty. On Fri, Jun 22, 2018 at 3:29 PM, Bill Bejeck wrote: > Hi John, > > Thanks for the KIP, and overall it's a +1 for me. > > In the JavaDoc for the segmentInterval

Re: [DISCUSS] KIP-319: Replace segments with segmentSize in WindowBytesStoreSupplier

Hi John, Thanks for the KIP, and overall it's a +1 for me. In the JavaDoc for the segmentInterval method, there's no mention of the number of segments there can be at any one time. While it's implied that the number of segments is potentially unbounded, would be better to explicitly state that

[VOTE] 0.11.0.3 RC0

Hello Kafka users, developers and client-developers, This is the first candidate for release of Apache Kafka 0.11.0.3. This is a bug fix release closing 27 tickets: https://cwiki.apache.org/confluence/display/KAFKA/Release+Plan+0.11.0.3 Release notes for the 0.11.0.3 release:

Re: [VOTE] 1.0.2 RC0

+1 Ran test suite. Checked signatures. On Fri, Jun 22, 2018 at 11:42 AM, Vahid S Hashemian < vahidhashem...@us.ibm.com> wrote: > +1 (non-binding) > > Built from source and ran quickstart successfully on Ubuntu (with Java 8). > > Thanks for running the release Matthias! > --Vahid > > > > >

Re: [VOTE] 1.1.1 RC1

+1 (non-binding) Built from source and ran quickstart successfully on Ubuntu (with Java 8). Thanks Dong! --Vahid From: Dong Lin To: dev@kafka.apache.org, us...@kafka.apache.org, kafka-clie...@googlegroups.com Date: 06/22/2018 10:10 AM Subject:[VOTE] 1.1.1 RC1 Hello Kafka

Build failed in Jenkins: kafka-2.0-jdk8 #53

See Changes: [rajinisivaram] MINOR: Cleanup threads in integration tests (#5269) -- [...truncated 2.61 MB...] org.apache.kafka.connect.runtime.WorkerConfigTransformerTest >

Re: [VOTE] 1.0.2 RC0

+1 (non-binding) Built from source and ran quickstart successfully on Ubuntu (with Java 8). Thanks for running the release Matthias! --Vahid From: "Matthias J. Sax" To: dev@kafka.apache.org, us...@kafka.apache.org, kafka-clie...@googlegroups.com Date: 06/22/2018 10:42 AM Subject:

[jira] [Created] (KAFKA-7091) AdminClient should handle FindCoordinatorResponse errors

Manikumar created KAFKA-7091: Summary: AdminClient should handle FindCoordinatorResponse errors Key: KAFKA-7091 URL: https://issues.apache.org/jira/browse/KAFKA-7091 Project: Kafka Issue Type:

Re: [DISCUSS] KIP-291: Have separate queues for control requests and data requests

Hi Eno, Sorry for the delayed response. - I haven't implemented the feature yet, so no experimental results so far. And I plan to test in out in the following days. - You are absolutely right that the priority queue does not completely prevent data requests being processed ahead of controller

[VOTE] 1.0.2 RC0

Hello Kafka users, developers and client-developers, This is the first candidate for release of Apache Kafka 1.0.2. This is a bug fix release closing 26 tickets: https://cwiki.apache.org/confluence/display/KAFKA/Release+Plan+1.0.2 Release notes for the 1.0.2 release:

Jenkins build is back to normal : kafka-trunk-jdk10 #245

See

Re: [VOTE] KIP-313: Add KStream.flatTransform and KStream.flatTransformValues

Thanks for the KIP, +1. -Bill On Fri, Jun 22, 2018 at 1:08 PM Ted Yu wrote: > +1 > > On Fri, Jun 22, 2018 at 2:50 AM, Bruno Cadonna wrote: > > > Hi list, > > > > I would like to voting on this KIP. > > > > I created a first PR[1] that adds flatTransform. Once I get some > > feedback, I will

[VOTE] 1.1.1 RC1

Hello Kafka users, developers and client-developers, This is the second candidate for release of Apache Kafka 1.1.1. Apache Kafka 1.1.1 is a bug-fix release for the 1.1 branch that was first released with 1.1.0 about 3 months ago. We have fixed about 25 issues since that release. A few of the

Re: [VOTE] KIP-313: Add KStream.flatTransform and KStream.flatTransformValues

+1 On Fri, Jun 22, 2018 at 2:50 AM, Bruno Cadonna wrote: > Hi list, > > I would like to voting on this KIP. > > I created a first PR[1] that adds flatTransform. Once I get some > feedback, I will start work on flatTransformValues. > > Best regards, > Bruno > > [1]

Re: [DISCUSS]KIP-216: IQ should throw different exceptions for different errors

Matthias, Thank you for your assistance. > what is the status of this KIP? Unfortunately, there is no further progress. About seven weeks ago, I was injured in sports. I had a broken wrist on my left wrist. Many jobs are affected, including this KIP and implementation. > I just re-read it,

Re: [VOTE] 2.0.0 RC0

Any and all testing is welcome, but testing in the following areas would be particularly helpful: 1. Performance and stress testing. Heroku and LinkedIn have helped with this in the past (and issues have been found and fixed). 2. Client developers can verify that their clients can

[jira] [Created] (KAFKA-7090) Zookeeper client setting in server-properties

Christian Tramnitz created KAFKA-7090: - Summary: Zookeeper client setting in server-properties Key: KAFKA-7090 URL: https://issues.apache.org/jira/browse/KAFKA-7090 Project: Kafka Issue

[VOTE] KIP-313: Add KStream.flatTransform and KStream.flatTransformValues

Hi list, I would like to voting on this KIP. I created a first PR[1] that adds flatTransform. Once I get some feedback, I will start work on flatTransformValues. Best regards, Bruno [1] https://github.com/apache/kafka/pull/5273

[DISCUSS] KIP-308: Support dynamic update of max.connections.per.ip/max.connections.per.ip.overrides configs

Hi all, I have created a KIP to add support for dynamic update of max.connections.per.ip/max.connections.per.ip.overrides configs *https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=85474993 * Any feedback