Re: Contribution help please

2021-09-19 Thread Boyang Chen
Have you checked out https://kafka.apache.org/coding-guide? On Fri, Sep 17, 2021 at 7:12 AM Jon McEwen wrote: > Hello Kafka folks, > > Could somone please tell me how to correctly format kafka Java code? > Either on command line or in IntelliJ. > > Many thanks > > Jon McEwen > >

Re: [DISCUSS] KIP-776: Add Consumer#peek for debugging/tuning

2021-09-19 Thread Boyang Chen
Thanks Luke for the KIP. I think I understand the motivation is to avoid affecting offset positions of the records, but the feature could be easily realized on the user side by using manual offset commit + offset position rewind. So the new peek() function doesn't provide any new functionality

Re: Contribute

2021-09-19 Thread Boyang Chen
Thanks for your interest in Kafka Soren, your account has been added. On Sun, Sep 19, 2021 at 10:38 AM Soren Schwartz wrote: > Hello, > > I would like to begin contribute. Following the guidelines I’m asked to > contact you such that I can use my JIRA account to assign myself to JIRA > tickets.

Contribute

2021-09-19 Thread Soren Schwartz
Hello, I would like to begin contribute. Following the guidelines I’m asked to contact you such that I can use my JIRA account to assign myself to JIRA tickets. Would this be possible – my JIRA account is: singingman Regards, Søren

Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #479

2021-09-19 Thread Apache Jenkins Server
See

KafkaProducer.configureTransactionState and overriding enable.idempotence

2021-09-19 Thread Jacek Laskowski
Hi, I found KafkaProducer.configureTransactionState [1] quite confusing and can't really understand what `if (userConfiguredTransactions && !userConfiguredIdempotence)` [2] is doing: if (userConfiguredTransactions && !userConfiguredIdempotence) log.info("Overriding the

[DISCUSS] KIP-776: Add Consumer#peek for debugging/tuning

2021-09-19 Thread Luke Chen
Hi everyone, I'd like to discuss the following proposal to add Consumer#peek for debugging/tuning. The main purpose for Consumer#peek is to allow users: 1. peek what records existed at broker side and not increasing the position offsets. 2. throw exceptions when there is connection

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #478

2021-09-19 Thread Apache Jenkins Server
See Changes: -- [...truncated 490375 lines...] [2021-09-19T07:03:46.031Z] AlterUserScramCredentialsRequestTest > testAlterNothing() STARTED [2021-09-19T07:03:49.791Z]