Re: Extracting key-value pair from Produce Request API.

Hi, I am looking at parsing Produce request API on broker side. This is for simulating a broker. No consumer is involved. Also, I am using 3.8.0. On Sat, 28 Dec, 2024, 04:47 Greg Harris, wrote: > Hi, > > Thanks for your question. > > It appears you're using the legacy consumer API, which was rem

Re: Extracting key-value pair from Produce Request API.

Hi, I am looking at parsing Produce request API on broker side. This is for simulating a broker. No consumer is involved. Also, I am using 3.8.0. On Sat, 28 Dec, 2024, 04:47 Greg Harris, wrote: > Hi, > > Thanks for your question. > > It appears you're using the legacy consumer API, which was rem

Re: Extracting key-value pair from Produce Request API.

Hi, Thanks for your question. It appears you're using the legacy consumer API, which was removed in 2.0.0 and is no longer supported. I would strongly suggest building on top of the modern Java Consumer API at this time. The modern API exposes the deserialized headers via the ConsumerRecord#head

Seeking Advice on Restricting Kafka ACLs for Specific Operations

Hello Folks, I'm encountering a challenge with Kafka ACLs related to "Alter Cluster" privileges. Currently, granting "Alter Cluster" allows users to manage their ACLs, as it inherits CREATE_ACLS and DELETE_ACLS. However, users can also add ClusterAction and AlterConfigs permissions on the "Clus

Extracting key-value pair from Produce Request API.

Hi, I am struggling to get the key-value pair from the Produce Request API. I want to write it to a Buffer for further processing. I can't seem to get the `k` and `v` values whereas the `.keySize` and `.valueSize` are reported correctly. Please advise how to extract the key value pairs from the Pro

Re: Extracting key-value pair from Produce Request API.

Hi, I apologize for misunderstanding your initial email. Unfortunately I still don't understand your question. Could you clarify what result you expect from your code, and what the actual behavior is? Maybe also try and simplify the reproduction case. I see confusing use of a String constructor t

RE: Seeking Advice on Restricting Kafka ACLs for Specific Operations

Am also posting this question in stack overflow. https://stackoverflow.com/questions/79312372/seeking-advice-on-restricting-kafka-acls-for-specific-operations From: Achar, Bharath Kumar Cm Sent: Friday, December 27, 2024 10:17 PM To: users@kafka.apache.org; users@kafka.apache.org Subject: Seeking