Re: Memory leak with kafka clients 3.0.0

Hi Willian, I don't see any recent Jiras that seem to cover this. I noticed two requests in the linked spring-kafka GitHub thread: 1. File a Jira on the Kafka project with relevant configuration, etc. 2. Provide a stripped-down, reproducible test case using Kafka (sans Spring) Having those tw

Re: [ANNOUNCE] New committer: Luke Chen

Congrats, Luke! On Wed, Feb 9, 2022, at 3:22 PM, Guozhang Wang wrote: > The PMC for Apache Kafka has invited Luke Chen (showuon) as a committer and > we are pleased to announce that he has accepted! > > Luke has been actively contributing to Kafka since early 2020. He has > made more than 120 com

Re: [ANNOUNCE] Apache Kafka 3.2.1

. > > A big thank you for the following 19 contributors to this release! > > Akhilesh Chaganti, Bruno Cadonna, Christopher L. Shannon, David > Arthur, Divij Vaidya, Eugene Tolbakov, Guozhang Wang, Ismael Juma, > James Hughes, Jason Gustafson, Kirk True, Lucas Bradstreet, Luke Chen,

Re: Consumer has high network bandwidth when consuming no messages

Hi Lee, Some questions: 1. Can you enable metrics for your consumer(s)? See [1] and [2] for links on consumer-level and fetch-level metrics, respectively. 2. Can you enable more detailed logging? 3. What do you mean specifically by “concurrency of 2?” 4. Can you verify the name of the fetch.wait

Re: How should I properly create the consumer group and reset the offset from all topics in kakfa CLI?

Hi! Did consumer group groupA exist before the --reset-offsets operation was performed? Thanks, Kirk On Fri, May 5, 2023, at 3:18 AM, choi ewain wrote: > Hello All. > > I am a newbie learning kakfa. > > I have 1000+topics in my kakfa, each topic contains 14 days of data, about > 120,000 mess

Re: Kafka OAuth authentication using OKTA

Hi Anup, I agree that the documentation could be improved. Are you able to provide the steps you did try and the specific error message you're seeing? Thanks, Kirk On Thu, Mar 27, 2025, at 10:02 AM, Shirolkar, Anup wrote: > Hi Team, > > I am trying to setup Kafka authentication using OAuth wi

Re: OAUTH ISSUE | Kafka v3.7.1

TopicCommand.java:437) > at > org.apache.kafka.tools.TopicCommand$TopicService.(TopicCommand.java:426) > at org.apache.kafka.tools.TopicCommand.execute(TopicCommand.java:98) > at > org.apache.kafka.tools.TopicCommand.mainNoExit(TopicCommand.java:87) > at

Re: Kraft with OAUTH and ACL

Hi Aniket, Are you using client-to-broker, broker-to-broker, or both? Thanks, Kirk On Mon, Mar 24, 2025, at 10:41 PM, Aniket Agarwal wrote: > Hello Team, > > I am trying to setup a Kraft Kafka server that uses OKTA for authentication > and I need authorisation based on client IDs. > > I am run

Re: OAUTH ISSUE | Kafka v3.7.1

ess token in the ACL to allow > read/write permissions on topics. Are you wanting to use Auth0 for both authentication and authorization instead of authentication via Auth0 and authorization via ACLs? Thanks, Kirk

Re: Support for other OAuth2 grant types in Kafka

o a > custom implementation as mentioned by you) That is correct. If you do end up writing another implementation, it would be great if it could be contributed back to the community. I'd love to see more additions in this area. Thanks, Kirk > On Wed, Feb 26, 2025 at 11:46 PM Kirk True

Re: Support for other OAuth2 grant types in Kafka

Hi Subra, I'm one of the authors of the OAuth support in Kafka. Answers to your questions are below... On Tue, Feb 25, 2025, at 3:05 AM, Subra I wrote: > Hello All, > > I see that Kafka by itself supports client credentials as grant type for > OAuth2. I see this mentioned in one of the kafka KI

Re: OAUTH ISSUE | Kafka v3.7.1

Hi Ashish, Are you using OAuth for client->broker communication, inter-broker communication, or both? Based on the server.properties configuration that was shared, it looks like the configuration is attempting to set up inter-broker communication using OAuth. For a broker to *retrieve* tokens