[jira] [Created] (KAFKA-19558) kafka-consumer-groups.sh --describe --all-groups command times out on large clusters with many consumer groups

zhangtongr created KAFKA-19558: -- Summary: kafka-consumer-groups.sh --describe --all-groups command times out on large clusters with many consumer groups Key: KAFKA-19558 URL: https://issues.apache.org/jira/browse/KAF

Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #373

See

[jira] [Created] (KAFKA-19557) Remove BrokerNotFoundException

Matthias J. Sax created KAFKA-19557: --- Summary: Remove BrokerNotFoundException Key: KAFKA-19557 URL: https://issues.apache.org/jira/browse/KAFKA-19557 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-12281) Cleanup unused org.apache.kafka.streams.errors.BrokerNotFoundException

[ https://issues.apache.org/jira/browse/KAFKA-12281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12281. - Fix Version/s: 4.1.0 Resolution: Fixed > Cleanup unused org.apache.kafka.streams.

Re: [DISCUSS] KIP-1159: Large message reference based Serializer

Hi, Omnia, Thanks for the updated KIP. A few more comments. JR11. value.serializers and value.deserializers: Should they be of type List? Also, where are key.serializers and key.deserializers? JR12. Do we still need ComposableSerializer and ComposableDeserializer? JR13. large.message.payload.st

Re: Request for Confluence Edit Permission

> > > I have received the notification about Confluence account created， But > when I clicked to change the password, it prompted" Too many attempts to reset password，I haven't received the email address for changing the password，and I didn't see the task email in the spam box either. I plan to tr

Re: [VOTE] 4.1.0 RC1

Hi, Quick update about the system tests. Streams: If I make the change suggested by Matthias, all the Streams tests pass. So we need to update the release process to not run into this issue. Either we don't only merge the RC tags into the release branch after the vote, or we update the logic to n

Re: Request for Confluence Edit Permission

Hi Corki, You should have permissions on confluence/wiki to create KIP and pages. Please let us know if you face any issues. Regards, Apoorv Mittal On Mon, Jul 28, 2025 at 5:28 PM Corki Oraen wrote: > > > > I just created a Confluence account, but it seems that the approval > > process hasn't

Re: Request for Confluence Edit Permission

> > I just created a Confluence account, but it seems that the approval > process hasn't been completed yet. The JIRA account was registered a long > time ago

Re: Request for Confluence Edit Permission

Hi Corki, Somehow I don't see the account on Confluence/Wiki with that username. Did you sign up for Confluence as well, however the jira account does exist? https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=50859233#KafkaImprovementProposals-Started Regards, Apoorv Mittal On Mon

Request for Confluence Edit Permission

Hi Kafka devs, I recently created a Confluence account with the username: corkitse. I'm planning to contribute a KIP related to adding max record count limit to FetchRequest. Could someone please grant me edit permissions on the Kafka wiki? Thanks a lot!

[jira] [Created] (KAFKA-19556) [Connect] Provide a configuration to disable SNI host checking for the REST API

Tamas Kornai created KAFKA-19556: Summary: [Connect] Provide a configuration to disable SNI host checking for the REST API Key: KAFKA-19556 URL: https://issues.apache.org/jira/browse/KAFKA-19556 Proje

Re: [DISCUSS] KIP-1187: Support to retrieve remote log size via DescribeLogDirs RPC

Hi Chia, Thanks for the review! > the `PartitionSize` does not include the `RemoteLogSize`, right? Yes, it is the local-log size. > Should we add similar fields for `TotalBytes` and `UsableBytes`? TotalBytes and UsableBytes may not be applicable for remote storage. As the storage implementer ca

[jira] [Resolved] (KAFKA-19425) local segment on disk never deleted forever when remote storage initial failed

[ https://issues.apache.org/jira/browse/KAFKA-19425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash resolved KAFKA-19425. -- Fix Version/s: 4.2.0 Resolution: Fixed > local segment on disk never de

[jira] [Resolved] (KAFKA-19551) Remove the handling of FatalExitError in RemoteStorageThreadPool

[ https://issues.apache.org/jira/browse/KAFKA-19551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash resolved KAFKA-19551. -- Fix Version/s: 4.2.0 Resolution: Fixed > Remove the handling of FatalEx

[jira] [Created] (KAFKA-19555) Restrict records acquisition post max inflight records

Apoorv Mittal created KAFKA-19555: - Summary: Restrict records acquisition post max inflight records Key: KAFKA-19555 URL: https://issues.apache.org/jira/browse/KAFKA-19555 Project: Kafka Issu

RE: [DISCUSS] KIP-780: Support fine-grained compression options

Hi Dongjin, Looking forward to your thoughts. Best, Maros Orsak On 2025/07/25 07:10:41 Maroš Orsák wrote: > Hi Dongjin, > > Hi Kafka devs, > > Thanks a lot for opening this KIP — and hats off for the amount of > benchmarking and investigation you’ve done! It’s great to see a follow-up > to KIP-

[jira] [Created] (KAFKA-19554) Add a Kafka client parameter to limit number of messages fetched

corkitse created KAFKA-19554: Summary: Add a Kafka client parameter to limit number of messages fetched Key: KAFKA-19554 URL: https://issues.apache.org/jira/browse/KAFKA-19554 Project: Kafka Iss

Re: Request to assign an issue (KAFKA-19425)

Hi Jian, Assigned to you. Thanks. Luke On Mon, Jul 28, 2025 at 3:47 PM jian fu wrote: > Hi team! > > Sorry to trouble you! I already fixed the issue: > https://issues.apache.org/jira/browse/KAFKA-19425 in > https://github.com/apache/kafka/pull/20007. > > Can you help to assign it to me direc

Request to assign an issue (KAFKA-19425)

Hi team! Sorry to trouble you! I already fixed the issue: https://issues.apache.org/jira/browse/KAFKA-19425 in https://github.com/apache/kafka/pull/20007. Can you help to assign it to me directly? thanks! My JIRA User information Username:fujian1115Full name:fujian Thank you! Regards Fu.Jia

Significant startup delay after upgrading kafka clients from 3.5.1 to 4.0.0

Hello Kafka devs, We’re in the process of upgrading our Kafka clients from version 3.5.1 to 4.0.0, and have observed a significant increase in startup time related to plugin loading. In version 3.5.1, plugin discovery completed in 30-40 seconds. After upgrading to 4.0.0, the same step takes ov