Re: [VOTE] KIP-382 MirrorMaker 2.0

+1 (binding). Nice work Ryan. -Harsha On Fri, Dec 21, 2018, at 8:14 AM, Andrew Schofield wrote: > +1 (non-binding) > > Andrew Schofield > IBM Event Streams > > On 21/12/2018, 01:23, "Srinivas Reddy" wrote: > > +1 (non binding) > > Thank you Ryan for the KIP, let me know if you

Re: KIP-408: Add Asynchronous Processing to Kafka Streams

Thanks Richard for proposing this feature! We also have encountered some similar feature request that we want to define a generic async processing API. However I guess the motivation here is that we should skip big records during normal

Re: KIP-408: Add Asynchronous Processing to Kafka Streams

Hi Boyang, Thanks for pointing out the possibility of skipping bad records (never crossed my mind). I suppose we could make it an option for the user if they could skip a bad record. It was never the intention of this KIP though on whether or not to do that. I could log a JIRA on such an issue,

Re: [DISCUSS] KIP-382: MirrorMaker 2.0

Hi Ryanne, just to briefly check in, am I understanding your mail correctly, that you want to pick up the "multi-cluster/herder/worker features" in a different KIP at some time? If yes, please feel free to let me know if I can provide any help on that front. Otherwise, I am also happy to draft a

Re: [VOTE] KIP-382 MirrorMaker 2.0

+1 (non-binding) Thanks for your effort Ryanne! On Fri, Dec 21, 2018 at 2:23 AM Srinivas Reddy wrote: > > +1 (non binding) > > Thank you Ryan for the KIP, let me know if you need support in implementing > it. > > - > Srinivas > > - Typed on tiny keys. pls ignore typos.{mobile app} > > > On Fri,

[VOTE] KIP-398: Support reading trust store from classpath

I’d like to call vote to my proposal KIP-398, about having the ability to read a trust store from classpath. This is a small but useful change that has the potential to benefit organisations that employ a private certificate infrastructure. cheers noa

Re: "version" in kafka-reassign-partitions's JSON input file is not updated by KIP-113

Any ideas why version has not been changed of the reassignment json file? If you generate it with kafka-reassign-partitions --zookeeper $(hostname -f):2181 --topics-to-move-json-file reassign.json --broker-list "26,27,28" --generate, you can see something like this: Current partition replica

Re: [VOTE] KIP-382 MirrorMaker 2.0

+1 (non-binding) Great stuff! Eno On Fri, Dec 21, 2018 at 10:04 AM Sönke Liebau wrote: > +1 (non-binding) > > Thanks for your effort Ryanne! > > On Fri, Dec 21, 2018 at 2:23 AM Srinivas Reddy > wrote: > > > > +1 (non binding) > > > > Thank you Ryan for the KIP, let me know if you need support

[jira] [Created] (KAFKA-7765) IdleExpiryManager should not passively close socket used by controller

huxihx created KAFKA-7765: - Summary: IdleExpiryManager should not passively close socket used by controller Key: KAFKA-7765 URL: https://issues.apache.org/jira/browse/KAFKA-7765 Project: Kafka

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

See Changes: [manikumar.reddy] MINOR: Switch anonymous classes to lambda expressions in tools module [manikumar.reddy] MINOR: Hygiene fixes in KafkaFutureImpl (#5098)

[jira] [Resolved] (KAFKA-7054) Kafka describe command should throw topic doesn't exist exception.

[ https://issues.apache.org/jira/browse/KAFKA-7054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7054. -- Resolution: Fixed Fix Version/s: 2.2.0 Issue resolved by pull request 5211

Re: Fail-fast builds?

Since this is a relatively simple change, I went ahead and opened up a PR here https://github.com/apache/kafka/pull/6059 On Fri, Dec 21, 2018 at 2:15 AM Manikumar wrote: > +1 fo the suggestion. > > On Fri, Dec 21, 2018 at 2:38 AM David Arthur wrote: > > > In the jenkins.sh file, we have the

Re: [VOTE] [REMINDER] KIP-383 Pluggable interface for SSL Factory

must be my gmail playing up. This appears to be the DISCUSS thread to me... On Thu, 20 Dec 2018 at 18:42, Harsha wrote: > Damian, >This is the VOTE thread. There is a DISCUSS thread which > concluded in it. > > -Harsha > > > On Wed, Dec 19, 2018, at 5:04 AM, Pellerin, Clement

Re: [DISCUSS] KIP-382: MirrorMaker 2.0

Sönke, I can probably get a KIP together in the next several weeks, but you're welcome to beat me to it :) Ryanne On Fri, Dec 21, 2018, 3:59 AM Sönke Liebau Hi Ryanne, > > just to briefly check in, am I understanding your mail correctly, that > you want to pick up the

[jira] [Created] (KAFKA-7766) Improve fail-fast behavior of Jenkins build

David Arthur created KAFKA-7766: --- Summary: Improve fail-fast behavior of Jenkins build Key: KAFKA-7766 URL: https://issues.apache.org/jira/browse/KAFKA-7766 Project: Kafka Issue Type: Task

Re: Fail-fast builds?

>>This would allow for fast failure on compilation and checkstyle problems, but let the whole test suite run in spite of test failures. +1 for that as it will be very useful. Thanks, Satish. On Fri, Dec 21, 2018 at 8:10 PM David Arthur wrote: > > Since this is a relatively simple change, I

Re: Problem in CI for pull request

Try typing "retest this please" as a comment to the PR. best, Colin On Wed, Nov 28, 2018, at 11:05, lk gen wrote: > Hi, > > I made a pull request and it passed CI on JDK 11 but failed on JDK 8 > > I think the JDK 8 error may not related to my commit but an environment > problem on the CI >

Re: [DISCUSS] KIP-252: Extend ACLs to allow filtering based on ip ranges and subnets

Hi Sönke, One path forward would be to forbid the new ACL types from being created until the inter-broker protocol had been upgraded. We'd also have to figure out how the new ACLs were stored in ZooKeeper. There are a bunch of proposals in this thread that could work for that-- I really hope

Re: [DISCUSS] KIP-388 Add observer interface to record request and response

On Thu, Nov 29, 2018, at 01:15, Lincong Li wrote: > Hi everyone, > > Thanks for all feedback on this KIP. I have had some lengthy offline > discussions with Dong, Joel and other insightful developers. I updated > KIP > 388 >

KIP-408: Add Asynchronous Processing to Kafka Streams

Hi all, Lately, there has been considerable interest in adding asynchronous processing to Kafka Streams. Here is the KIP for such an addition: https://cwiki.apache.org/confluence/display/KAFKA/KIP-408%3A+Add+Asynchronous+Processing+To+Kafka+Streams I wish to discuss the best ways to approach

Re: [DISCUSS] KIP-345: Reduce multiple consumer rebalances by specifying member id

Hi Boyang, Regarding "However, we shall still attempt to remove the member static info if the given `member.id` points to an existing `group.instance.id` upon LeaveGroupRequest, because I could think of the possibility that in long term we could want to add static membership leave group logic for

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

See

Re: [VOTE] KIP-382 MirrorMaker 2.0

+1 (non-binding) Andrew Schofield IBM Event Streams On 21/12/2018, 01:23, "Srinivas Reddy" wrote: +1 (non binding) Thank you Ryan for the KIP, let me know if you need support in implementing it. - Srinivas - Typed on tiny keys. pls ignore typos.{mobile