Build failed in Jenkins: kafka-2.5-jdk8 #40

See Changes: [jason] KAFKA-9577; SaslClientAuthenticator incorrectly negotiates -- [...truncated 2.90 MB...] org.apache.kafka.streams.MockProcessorContextTest > shouldCapture

Jenkins build is back to normal : kafka-trunk-jdk11 #1182

See

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

Good find Vito! What Navinder says makes sense -- as there is no RC for 2.5.0 yet, I took the liberty to do a HOTFIX PR so we can address the issue in 2.5.0 already. https://github.com/apache/kafka/pull/8158 -Matthias On 2/21/20 11:11 PM, Navinder Brar wrote: > Hi Vito, > > I checked the code

Re: Request for adding wiki edit permission for creating KIP

Done. (Sorry for the delay) On 2/11/20 3:53 PM, Xue LIU wrote: > Hi guys, > > I am Xue, just joined this mailing list. Being new to Kafka developer > community, I am very glad to join and any help/guide is greatly appreciated! > > I am working on this JIRA: https://issues.apache.org/jira/brows

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

Thanks Navinder and Matthias. --- Vito On Sat, Feb 22, 2020 at 8:12 PM Matthias J. Sax wrote: > Good find Vito! > > What Navinder says makes sense -- as there is no RC for 2.5.0 yet, I > took the liberty to do a HOTFIX PR so we can address the issue in 2.5.0 > already. > > https://github.com/a

Adding myself to contributors list

Hey, I would like to contribute to kafka, can you please add me to Jira? Is there any good way to start contributing in your opinion? PL - Scala,Java Name - Mathew Kuriakose Thanks, mathew

Re: Adding myself to contributors list

Hi Mathew, Welcome to the community! What is your JIRA username? I searched for your name but couldn't find you. To get started I recommend taking a look at this guide: http://kafka.apache.org/contributing There's also a list of beginner bugs: https://issues.apache.org/jira/issues/?jql=project%2

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

See Changes: [manikumar] MINOR: set scala version automatically based on gradle.properties -- [...truncated 2.88 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

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

See Changes: [manikumar] MINOR: set scala version automatically based on gradle.properties -- [...truncated 2.90 MB...] org.apache.kafka.streams.internals.WindowStoreFa

Re: [KAFKA-557] Add emit on change support for Kafka Streams

Hi all, Updated the KIP. Just a question: do you think it would be a good idea if we check for both Object#equals() and binary equality? Because there might be some subtle changes in the serialization (for example, if the user decides to upgrade their serialization procedure to a new one), but th

[jira] [Resolved] (KAFKA-9582) Ensure EOS task producer not through fatal error in unclean shutdown

[ https://issues.apache.org/jira/browse/KAFKA-9582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9582. Resolution: Fixed > Ensure EOS task producer not through fatal error in unclean shutdown >

[jira] [Resolved] (KAFKA-9441) Refactor commit logic

[ https://issues.apache.org/jira/browse/KAFKA-9441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9441. Resolution: Fixed > Refactor commit logic > - > > Key: KAFKA-94

回复：[Discuss] KIP-571: Add option to force remove members in StreamsResetter

Hi, Boyang Thanks for your review, I have updated the KIP page :) Hi, Sophie Thanks for your suggestions! 1) Did you consider an API that just removes *all* remaining members from a group? We plan to implement the batch removal in StreamsResetter as below: 1) adminClient