Request to become a contributor

Hi team, Request you to add me to the contributor list. JIRA username: amrutha.shanbhag Thanks, *Amrutha Shanbhag**Senior Software Engineer* Read our latest technical blo

Nag! Feedback needed for KAFKA-8676

Hi, I have opened a JIRA ticket and a corresponding pull request for it. I think the problems mentioned in the JIRA ticket has been resolved in the pull request. Could someone review the change? Thanks in advance. Best, Luying

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

See Changes: [github] MINOR: Fix Streams metadata upgrade system test (#7118) -- [...truncated 2.57 MB...] org.apache.kafka.connect.runtime.distributed.WorkerCoordinatorTe

[jira] [Created] (KAFKA-8724) log cleaner thread dies when attempting to clean a __consumer_offsets partition after upgrade from 2.0->2.3

Keith So created KAFKA-8724: --- Summary: log cleaner thread dies when attempting to clean a __consumer_offsets partition after upgrade from 2.0->2.3 Key: KAFKA-8724 URL: https://issues.apache.org/jira/browse/KAFKA-8724

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

See Changes: [github] MINOR: Fix Streams metadata upgrade system test (#7118) -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remote

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

See Changes: [github] MINOR: Remove unused TopicAndPartition and remove unused symbols (#7119) -- [...truncated 2.58 MB...] org.apache.kafka.streams.scala.kstream.Suppre

Re: Build failed in Jenkins: kafka-trunk-jdk8 #3815

m On Sun, Jul 28, 2019 at 10:42 PM Apache Jenkins Server < jenk...@builds.apache.org> wrote: > See < > https://builds.apache.org/job/kafka-trunk-jdk8/3815/display/redirect?page=changes > > > > Changes: > > [github] MINOR: Remove unused TopicAndPartition and remove unused symbols > (#7119) > > ---

Re: [DISCUSS] KIP-497: Add inter-broker API to alter ISR

Hi Jason, This looks good. If the AlterIsr request returns a higher ZK version than the one the broker currently has, will the broker use that as its new ZK version? I suppose this could happen if some of the updates the controller pushed out were not received or not received yet by the broke

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

See Changes: [github] MINOR: Remove unused TopicAndPartition and remove unused symbols (#7119) -- Started by an SCM change [EnvInject] - Loading node environment variable

[DISCUSS] KIP-498: Add client-side configuration for maximum response size to protect against OOM

Hello, I have created the KIP-498 to propose a minor addition to the producer configuration properties, in order to protect against OOM when the response me

Re: [DISCUSS] KIP-490: log when consumer groups lose a message because offset has been deleted

Hello, Thanks for taking the time to review my KIP! I will describe some production scenarios I faced to better explain the reasons for this KIP. * Usecase 1: batch processing of files. A batch is producing huge files that must be processed. Each line of the file will be a message produced to a

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

See Changes: [ismael] MINOR: Close ZKDatabase in EmbeddedZookeeper (#6237) -- [...truncated 6.45 MB...] org.apache.kafka.connect.util.KafkaBasedLogTest > testStartStop ST

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

See