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

2018-04-15 Thread Apache Jenkins Server
See

[jira] [Created] (KAFKA-6792) Wrong pointer in the link for stream dsl

2018-04-15 Thread robin m (JIRA)
robin m created KAFKA-6792: -- Summary: Wrong pointer in the link for stream dsl Key: KAFKA-6792 URL: https://issues.apache.org/jira/browse/KAFKA-6792 Project: Kafka Issue Type: Bug Report

Re: [VOTE] KIP-265: Make Windowed Serde to public APIs

2018-04-15 Thread Guozhang Wang
Hello folks, I have updated KIP-265 a bit on the window serde configuration logic, based on the decisions we made during the implementation of the two JIRAs. Please feel free to read the updated wiki page: https://cwiki.apache.org/confluence/display/KAFKA/KIP-265%3A+Make+Windowed+Serde+to+public+

[jira] [Resolved] (KAFKA-6531) SocketServerTest#closingChannelException fails sometimes

2018-04-15 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-6531. --- Resolution: Cannot Reproduce > SocketServerTest#closingChannelException fails sometimes >

Jenkins build is back to normal : kafka-trunk-jdk8 #2550

2018-04-15 Thread Apache Jenkins Server
See

Re: [VOTE] KIP-279: Fix log divergence between leader and follower after fast leader fail over

2018-04-15 Thread Damian Guy
Thanks Anna +1 On Sun, 15 Apr 2018 at 15:40, Guozhang Wang wrote: > Anna, thanks for the KIP! +1 from me. > > Just one minor comment: `Broker A will respond with offset 11`, seems it > should be `21`. > > On Sun, Apr 15, 2018 at 3:48 AM, Dong Lin wrote: > > > Thanks for the KIP! LGTM. +1 > > > >

Re: [DISCUSS] KIP-276: Add StreamsConfig prefix for different consumers

2018-04-15 Thread Boyang Chen
Hey Ewen, in case you don't have any further concern, I shall move this KIP to the voting stage. Let me know your thoughts. Thank you! From: Boyang Chen Sent: Sunday, April 15, 2018 4:25 AM To: dev@kafka.apache.org Subject: Re: [DISCUSS] KIP-276: Add Streams

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

2018-04-15 Thread Apache Jenkins Server
See Changes: [wangguoz] KAFKA-6790: Fix Streams processor node broken link (#4874) -- [...truncated 3.53 MB...] kafka.zookeeper.ZooKeeperClientTest > testPipelinedGetData

Jenkins build is back to normal : kafka-trunk-jdk7 #3338

2018-04-15 Thread Apache Jenkins Server
See

Build failed in Jenkins: kafka-trunk-jdk10 #17

2018-04-15 Thread Apache Jenkins Server
See Changes: [github] KAFKA-6058: Refactor consumer API result return types (#4856) [github] KAFKA-6611, PART II: Improve Streams SimpleBenchmark (#4854) -- [...truncated

Build failed in Jenkins: kafka-trunk-jdk10 #16

2018-04-15 Thread Apache Jenkins Server
See Changes: [wangguoz] KAFKA-6790: Fix Streams processor node broken link (#4874) -- [...truncated 1.65 MB...] at org.gradle.api.internal.tasks.testing.results.Te

[jira] [Resolved] (KAFKA-6058) KIP-222: Add "describe consumer groups" and "list consumer groups" to KafkaAdminClient

2018-04-15 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6058. -- Resolution: Fixed > KIP-222: Add "describe consumer groups" and "list consumer groups" to > Kaf

Re: [VOTE] KIP-222 - Add "describe consumer group" to KafkaAdminClient

2018-04-15 Thread Guozhang Wang
Hello folks, I have update the KIP-222 wiki slightly upon the discussions we had during the implementations of the KIP. Please find more information on the following PRs: https://github.com/apache/kafka/pull/4454 https://github.com/apache/kafka/pull/4856 Guozhang On Tue, Feb 6, 2018 at 2:33 P

[jira] [Resolved] (KAFKA-6790) Broken link in documentation for processor nodes

2018-04-15 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6790. -- Resolution: Fixed Fix Version/s: 1.1.0 > Broken link in documentation for processor nodes

[jira] [Created] (KAFKA-6791) Add a CoordinatorNodeProvider in KafkaAdminClient

2018-04-15 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6791: Summary: Add a CoordinatorNodeProvider in KafkaAdminClient Key: KAFKA-6791 URL: https://issues.apache.org/jira/browse/KAFKA-6791 Project: Kafka Issue Type: I

Re: [VOTE] KIP-279: Fix log divergence between leader and follower after fast leader fail over

2018-04-15 Thread Guozhang Wang
Anna, thanks for the KIP! +1 from me. Just one minor comment: `Broker A will respond with offset 11`, seems it should be `21`. On Sun, Apr 15, 2018 at 3:48 AM, Dong Lin wrote: > Thanks for the KIP! LGTM. +1 > > On Sat, Apr 14, 2018 at 5:31 PM, Ted Yu wrote: > > > +1 > > > > On Sat, Apr 14, 201

Re: [VOTE] KIP-279: Fix log divergence between leader and follower after fast leader fail over

2018-04-15 Thread Dong Lin
Thanks for the KIP! LGTM. +1 On Sat, Apr 14, 2018 at 5:31 PM, Ted Yu wrote: > +1 > > On Sat, Apr 14, 2018 at 3:54 PM, Anna Povzner wrote: > > > Hi All, > > > > > > I would like to start the vote on KIP-279: Fix log divergence between > > leader and follower after fast leader fail over. > > > >

Re: [VOTE] #2 KIP-248: Create New ConfigCommand That Uses The New AdminClient

2018-04-15 Thread Ted Yu
+1 Original message From: zhenya Sun Date: 4/15/18 12:42 AM (GMT-08:00) To: dev Cc: dev Subject: Re: [VOTE] #2 KIP-248: Create New ConfigCommand That Uses The New AdminClient non-binding +1 from my iphone! On 04/15/2018 15:41, Attila Sasvári wrote: Thanks for updating

Re: [VOTE] #2 KIP-248: Create New ConfigCommand That Uses The New AdminClient

2018-04-15 Thread zhenya Sun
non-binding +1 from my iphone! On 04/15/2018 15:41, Attila Sasvári wrote: Thanks for updating the KIP. +1 (non-binding) Viktor Somogyi ezt írta (időpont: 2018. ápr. 9., H 16:49): > Hi Magnus, > > Thanks for the heads up, added the endianness to the KIP. Here is the > current text: > > "Dou

Re: [VOTE] #2 KIP-248: Create New ConfigCommand That Uses The New AdminClient

2018-04-15 Thread Attila Sasvári
Thanks for updating the KIP. +1 (non-binding) Viktor Somogyi ezt írta (időpont: 2018. ápr. 9., H 16:49): > Hi Magnus, > > Thanks for the heads up, added the endianness to the KIP. Here is the > current text: > > "Double > A new type needs to be added to transfer quota values. Since the protocol