[jira] [Resolved] (KAFKA-6352) Delay message down-conversion until response is ready to be sent

[ https://issues.apache.org/jira/browse/KAFKA-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6352. Resolution: Not A Problem This was addressed by

[jira] [Resolved] (KAFKA-7183) Add a trogdor test that creates many connections to brokers

[ https://issues.apache.org/jira/browse/KAFKA-7183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-7183. Resolution: Fixed > Add a trogdor test that creates many connections to brokers >

[DISCUSS] KIP-392: Allow consumers to fetch from the closest replica

Hi All, I've posted a KIP to add the often-requested support for fetching from followers: https://cwiki.apache.org/confluence/display/KAFKA/KIP-392%3A+Allow+consumers+to+fetch+from+closest+replica. Please take a look and let me know what you think. Thanks, Jason

Re: [ANNOUNCE] Apache Kafka 2.1.0

Bravo Dong! Thanks for managing the 2.1.0 release. Edo sent from my phone On Wed, 21 Nov 2018, 20:41 James Cheng Thanks Dong for running the release, and congrats to everyone in the > community! > > -James > > Sent from my iPhone > > > On Nov 21, 2018, at 10:09 AM, Dong Lin

Re: [DISCUSS] KIP-392: Allow consumers to fetch from the closest replica

I didn't review yet, and I'm sure there are many details to iron out. But my thoughts are: OMG. YES. THANK YOU. On Wed, Nov 21, 2018 at 12:54 PM Jason Gustafson wrote: > > Hi All, > > I've posted a KIP to add the often-requested support for fetching from > followers: >

[jira] [Resolved] (KAFKA-5775) Implement Fault Injection testing for Kafka

[ https://issues.apache.org/jira/browse/KAFKA-5775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-5775. Resolution: Fixed > Implement Fault Injection testing for Kafka >

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

See

Build failed in Jenkins: kafka-trunk-jdk11 #111

See Changes: [wangguoz] MINOR: increase system test kafka start timeout (#5934) -- [...truncated 2.25 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

[jira] [Resolved] (KAFKA-6372) Trogdor should use LogContext for log messages

[ https://issues.apache.org/jira/browse/KAFKA-6372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-6372. Resolution: Fixed > Trogdor should use LogContext for log messages >

[jira] [Resolved] (KAFKA-5110) ConsumerGroupCommand error handling improvement

[ https://issues.apache.org/jira/browse/KAFKA-5110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5110. Resolution: Won't Fix Closing this as "won't fix" for now. The consumer group command no

[jira] [Resolved] (KAFKA-7231) NetworkClient.newClientRequest() ignores custom request timeout in favor of the default

[ https://issues.apache.org/jira/browse/KAFKA-7231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7231. Resolution: Fixed Fix Version/s: 2.0.1 2.1.0 >

[jira] [Resolved] (KAFKA-2931) Consumer rolling upgrade test case

[ https://issues.apache.org/jira/browse/KAFKA-2931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-2931. Resolution: Fixed This was resolved by https://github.com/apache/kafka/pull/619. >

Re: [ANNOUNCE] Apache Kafka 2.1.0

Thanks Dong for running the release, and congrats to everyone in the community! -James Sent from my iPhone > On Nov 21, 2018, at 10:09 AM, Dong Lin wrote: > > The Apache Kafka community is pleased to announce the release for Apache > Kafka 2.1.0 > > > This is a major release and includes

[jira] [Resolved] (KAFKA-7428) ConnectionStressSpec: add "action", allow multiple clients

[ https://issues.apache.org/jira/browse/KAFKA-7428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-7428. Resolution: Fixed > ConnectionStressSpec: add "action", allow multiple clients >

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

See Changes: [mjsax] MINOR: Update docs with out-dated context.schedule(...) examples (#5924) -- [...truncated 2.38 MB...]

Re: [ANNOUNCE] Apache Kafka 2.1.0

Awesome! Thank you Dong for running the release. --Vahid On Wed, Nov 21, 2018 at 1:00 PM Edoardo Comar wrote: > Bravo Dong! > Thanks for managing the 2.1.0 release. > > Edo > > sent from my phone > > On Wed, 21 Nov 2018, 20:41 James Cheng > > Thanks Dong for running the

[jira] [Resolved] (KAFKA-6696) Trogdor should support destroying tasks

[ https://issues.apache.org/jira/browse/KAFKA-6696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-6696. Resolution: Fixed > Trogdor should support destroying tasks >

[jira] [Resolved] (KAFKA-6785) Add Trogdor documentation

[ https://issues.apache.org/jira/browse/KAFKA-6785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-6785. Resolution: Fixed > Add Trogdor documentation > - > >

RE: [DISCUSS] KIP-383 Pluggable interface for SSL Factory

This turned out to be trickier than I thought and I don't have a firm solution yet. Since SslFactory will handle reconfiguration, the idea is to make the configuration immutable in the pluggable factory. SslFactory would create a new pluggable factory every time the configuration changes. The

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

Hey Dong, sorry for missing your message. I couldn't find your email on my thread, so I will just do a checklist here! 1) The motivation currently explicitly states that the goal is to improve performance for heavy state application. It seems that the motivation can be stronger with the

Re: [KAFKA-7382] Guarantee atleast one replica of partition to be alive during topic creation

Committers, Please check this. On Thu, Nov 15, 2018 at 1:01 PM Suman B N wrote: > Any update on this? > > On Tue, Nov 13, 2018 at 1:17 PM Suman B N wrote: > >> Team, >> >> Review and merge - https://github.com/apache/kafka/pull/5822. >> One round of review has been done by Mani Kumar Reddy in

[ANNOUNCE] Apache Kafka 2.1.0

The Apache Kafka community is pleased to announce the release for Apache Kafka 2.1.0 This is a major release and includes significant features from 28 KIPs. It contains fixes and improvements from 179 JIRSs, including a few critical bug fixes. Here is a summary of some notable changes ** Java

Re: [ANNOUNCE] Apache Kafka 2.1.0

Great! Thanks Dong for running the release On Wed, Nov 21, 2018 at 6:09 PM Dong Lin wrote: > > The Apache Kafka community is pleased to announce the release for Apache > Kafka 2.1.0 > > > This is a major release and includes significant features from 28 KIPs. It > contains fixes and improvements

Re: [ANNOUNCE] Apache Kafka 2.1.0

Thanks for running the release Dong and thanks to all who contributed to the release! Ismael On Wed, Nov 21, 2018, 10:09 AM Dong Lin The Apache Kafka community is pleased to announce the release for Apache > Kafka 2.1.0 > > > This is a major release and includes significant features from 28

Re: [ANNOUNCE] Apache Kafka 2.1.0

Thanks Dong for driving the release!! Guozhang On Wed, Nov 21, 2018 at 10:09 AM Dong Lin wrote: > The Apache Kafka community is pleased to announce the release for Apache > Kafka 2.1.0 > > > This is a major release and includes significant features from 28 KIPs. It > contains fixes and

[DISCUSS] KIP-391: Allow Producing with Offsets for Cluster Replication

Hi, we've opened a KIP to improve data replication between Kafka clusters : https://cwiki.apache.org/confluence/display/KAFKA/KIP-391%3A+Allow+Producing+with+Offsets+for+Cluster+Replication We'd like to start a discussion, please post your feedback in this thread. Thank you Edo and Mickael

[jira] [Created] (KAFKA-7666) KIP-391: Allow Producing with Offsets for Cluster Replication

Edoardo Comar created KAFKA-7666: Summary: KIP-391: Allow Producing with Offsets for Cluster Replication Key: KAFKA-7666 URL: https://issues.apache.org/jira/browse/KAFKA-7666 Project: Kafka