Re: [PR] Add Reddit as powered by Kafka [kafka-site]

kamalcph merged PR #662: URL: https://github.com/apache/kafka-site/pull/662 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: dev-unsubscr...@kafka.apache

Re: [VOTE] KIP-1126: Serialize changes to Kafka with a build queue

Thanks for the KIP, +1 (binding). Ismael On Wed, Feb 12, 2025 at 6:16 AM David Arthur wrote: > Hey folks, I'd like to start the vote on this KIP to enable the merge queue > for Kafka. > > The discussion thread is here: > https://lists.apache.org/thread/c446mf4bg0ocjgs6do9lltoc2f13r71m > > -- >

[jira] [Resolved] (KAFKA-18728) Move ListOffsetsPartitionStatus to server module

[ https://issues.apache.org/jira/browse/KAFKA-18728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash resolved KAFKA-18728. -- Fix Version/s: 4.1.0 Resolution: Fixed > Move ListOffsetsPartitionStatu

Re: [DISCUSS] KIP-584: Versioning scheme for features

hi All, I noticed that while the discussion seemed to include the functionality to retrieve supported features from a specific broker, the final implementation appears to fetch this information from a "random" broker. I have filed KAFKA-18786 to address this discrepancy, but I would appreciate

[jira] [Created] (KAFKA-18786) Enable returnning supported features from a specific broker

Chia-Ping Tsai created KAFKA-18786: -- Summary: Enable returnning supported features from a specific broker Key: KAFKA-18786 URL: https://issues.apache.org/jira/browse/KAFKA-18786 Project: Kafka

Introduction and Contribution to Kafka

Hi Team, I’m new here and looking forward to contributing to Kafka! I specialize in code clean-up, refactoring, writing and fixing unit tests, and bug fixes. So far, I’ve worked on the following contributions: KAFKA-10789:https://github.com/apache/kafka/pull/18816 KAFKA-18461:https://github.com/

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

See

[jira] [Created] (KAFKA-18785) Add emitStrategy for co-grouped windowed aggrgation

Matthias J. Sax created KAFKA-18785: --- Summary: Add emitStrategy for co-grouped windowed aggrgation Key: KAFKA-18785 URL: https://issues.apache.org/jira/browse/KAFKA-18785 Project: Kafka Iss

Confluence access

Hi, Could someone give me access to the Kafka Confluence space at https://cwiki.apache.org/confluence/display/kafka? I'd like to write a KIP. My confluence user is "gongxuanzhang"

[jira] [Created] (KAFKA-18784) Fix ConsumerWithLegacyMessageFormatIntegrationTest

Ismael Juma created KAFKA-18784: --- Summary: Fix ConsumerWithLegacyMessageFormatIntegrationTest Key: KAFKA-18784 URL: https://issues.apache.org/jira/browse/KAFKA-18784 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-18781) Extend RefreshRetriableException based exceptions

Kaushik Raina created KAFKA-18781: - Summary: Extend RefreshRetriableException based exceptions Key: KAFKA-18781 URL: https://issues.apache.org/jira/browse/KAFKA-18781 Project: Kafka Issue Typ

[jira] [Resolved] (KAFKA-18769) Handle leader changes in client to ensure we do not send requests to the previous leader

[ https://issues.apache.org/jira/browse/KAFKA-18769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shivsundar R resolved KAFKA-18769. -- Resolution: Fixed > Handle leader changes in client to ensure we do not send requests to the

Re: Manage dynamic members through java admin client

Hi, Just pushed the PoC making it working based on spring kafka listener container. The main point is about using ConsumerRebalanceListener to watch for changed in the partition the consumer member is bound to, and take advantage of spring container to make it pausing. Relevant code here https://g

[VOTE] KIP-1124: Providing a clear Kafka Client upgrade path

Hello, I'd like to initiate a vote on KIP-1124, which aims to provide a clear upgrade path for Kafka clients. This proposal will not only help users transition smoothly but also reduce the development effort required to support upgrades. Discuss Thread: https://lists.apache.org/thread/v7by71w1cmn4

[VOTE] KIP-1126: Serialize changes to Kafka with a build queue

Hey folks, I'd like to start the vote on this KIP to enable the merge queue for Kafka. The discussion thread is here: https://lists.apache.org/thread/c446mf4bg0ocjgs6do9lltoc2f13r71m -- David Arthur

[jira] [Resolved] (KAFKA-18777) add `PartitionsWithLateTransactionsCount` to BrokerMetricNamesTest

[ https://issues.apache.org/jira/browse/KAFKA-18777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18777. Fix Version/s: 4.1.0 Resolution: Fixed > add `PartitionsWithLateTransactionsCount`

[jira] [Created] (KAFKA-18783) Extend InvalidConfigurationException related exceptions

Kaushik Raina created KAFKA-18783: - Summary: Extend InvalidConfigurationException related exceptions Key: KAFKA-18783 URL: https://issues.apache.org/jira/browse/KAFKA-18783 Project: Kafka Iss

[jira] [Created] (KAFKA-18782) Extemd ApplicationRecoverableException related exceptions

Kaushik Raina created KAFKA-18782: - Summary: Extemd ApplicationRecoverableException related exceptions Key: KAFKA-18782 URL: https://issues.apache.org/jira/browse/KAFKA-18782 Project: Kafka I

[jira] [Created] (KAFKA-18780) Extend all RetriableException related exceptions

Kaushik Raina created KAFKA-18780: - Summary: Extend all RetriableException related exceptions Key: KAFKA-18780 URL: https://issues.apache.org/jira/browse/KAFKA-18780 Project: Kafka Issue Type

[jira] [Created] (KAFKA-18779) Validate responses from broker in ShareConsumeRequestManager.

Shivsundar R created KAFKA-18779: Summary: Validate responses from broker in ShareConsumeRequestManager. Key: KAFKA-18779 URL: https://issues.apache.org/jira/browse/KAFKA-18779 Project: Kafka

[jira] [Created] (KAFKA-18778) Fix the inconsistent lastest supported version in StorageTool.scala and FutureCommand

黃竣陽 created KAFKA-18778: --- Summary: Fix the inconsistent lastest supported version in StorageTool.scala and FutureCommand Key: KAFKA-18778 URL: https://issues.apache.org/jira/browse/KAFKA-18778 Project: Kafka

[jira] [Resolved] (KAFKA-18756) Add share group configs to system tests

[ https://issues.apache.org/jira/browse/KAFKA-18756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-18756. -- Fix Version/s: 4.1.0 Resolution: Fixed > Add share group configs to system test

[jira] [Resolved] (KAFKA-18763) Resolve the flakiness in test_share_single_topic_partition system test

[ https://issues.apache.org/jira/browse/KAFKA-18763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-18763. -- Fix Version/s: 4.1.0 Resolution: Fixed > Resolve the flakiness in test_share_si

[jira] [Resolved] (KAFKA-18764) Cluster-authorized share-state RPCs should throttle when not authorized

[ https://issues.apache.org/jira/browse/KAFKA-18764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-18764. -- Resolution: Fixed > Cluster-authorized share-state RPCs should throttle when not autho

Re: [VOTE] KIP-1111: Enforcing Explicit Naming for Kafka Streams Internal Topics

Hey. Just a note about KIP-: We accepted this KIP, and the main proposal is a new config which optionally treats any implicitly named internal topic as fatal. However, the KIP also proposes logging a WARN message about every topic / internal topic that has an auto-generated name even when the

[jira] [Resolved] (KAFKA-18771) Flaky test KRaftClusterTest .testDescribeQuorumRequestToControllers

[ https://issues.apache.org/jira/browse/KAFKA-18771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-18771. --- Fix Version/s: 4.0.0 Resolution: Fixed > Flaky test KRaftClusterTest .testDescribeQuorumReque