[jira] [Resolved] (KAFKA-17847) Avoid the extra bytes copy when compressing telemetry payload

[ https://issues.apache.org/jira/browse/KAFKA-17847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17847. Fix Version/s: 4.0.0 Resolution: Fixed > Avoid the extra bytes copy when compressin

Re: [DISCUSS] KIP-1097: error record reporter

Hi Anton, Thanks for the KIP! I think that looking at internal APIs as inspiration for new external APIs is a good idea, and I'm glad that you found an interface close to the problem you're trying to solve. What sort of implementation do you have in mind for this interface? What use-case does thi

Re: [DISCUSS] KIP-1097: error record reporter

Bumping the thread. Please review this KIP. Thanks! On Sun, Oct 13, 2024 at 11:44 PM Anton Liauchuk wrote: > > Hi all, > > I have opened > https://cwiki.apache.org/confluence/display/KAFKA/KIP-1097+error+record+reporter > > POC: https://github.com/apache/kafka/pull/17493 > > Please review KIP an

[jira] [Created] (KAFKA-17867) Consider using zero-copy for PushTelemetryRequest

Chia-Ping Tsai created KAFKA-17867: -- Summary: Consider using zero-copy for PushTelemetryRequest Key: KAFKA-17867 URL: https://issues.apache.org/jira/browse/KAFKA-17867 Project: Kafka Issue T

Re: [VOTE] 3.9.0 RC3

Hi Colin, Thanks for handling the release of the new RC. I built from source and ran all the unit and integration tests on each combination of different LTS JDK versions and distributions in Docker (Zulu and Corretto). +1 (non-binding) Thanks, TengYao Justine Olshan 於 2024年10月24日 週四 下午2:24寫道：

[jira] [Resolved] (KAFKA-16649) Remove lock from DynamicBrokerConfig.removeReconfigurable

[ https://issues.apache.org/jira/browse/KAFKA-16649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16649. Fix Version/s: 4.0.0 Assignee: Colin McCabe Resolution: Fixed > Remove loc

Re: [VOTE] 3.8.1 RC1

Hi Josep, Thanks for handling the release of the 3.8.1 RC. I did the following: - Built from source using different LTS JDK versions (8 to 21) and distributions in Docker (Zulu and Corretto) - Ran all the unit tests in each container There were a few failures during the first run, but when I tes

[jira] [Created] (KAFKA-17875) Aligh KRaft controller count recommendations

Mickael Maison created KAFKA-17875: -- Summary: Aligh KRaft controller count recommendations Key: KAFKA-17875 URL: https://issues.apache.org/jira/browse/KAFKA-17875 Project: Kafka Issue Type:

Re: [VOTE] 3.9.0 RC3

Hi Colin, I opened a PR to add the limitation section in the "Controller membership changes" chapter. If there are other things needed to be added, please let me know. But since it's only doc change, it won't block the RC voting. Thanks. Luke On Fri,

Re: [VOTE] 3.8.1 RC1

Hi Josep, +1 (binding) I did the following - checked the checksums and signatures - ran quickstart with the 2.13 binaries, docker and docker-native image - built and ran tests from source Thanks, Mickael On Thu, Oct 24, 2024 at 8:03 PM Josep Prat wrote: > > Hi all! > Gentle ping on this threa

[jira] [Created] (KAFKA-17874) Fix the KRaft metric names in the documentation

Mickael Maison created KAFKA-17874: -- Summary: Fix the KRaft metric names in the documentation Key: KAFKA-17874 URL: https://issues.apache.org/jira/browse/KAFKA-17874 Project: Kafka Issue Typ

Re: [DISCUSS] KIP-1099: Extend kafka-consumer-groups command line tool to support new consumer group

Hi Lucas, Thanks for the review! 1) Yes, I add related change for kafka-share-groups.sh to the KIP. Could you take a look? Thanks for the suggestion. 2) We use CONSUMER-ID as member ID. If we use MEMBER-EPOCH here, users may confuse what is different between CONSUMER and MEMBER. Thanks, PoAn

Re: [DISCUSS] KIP-1098: Reverse Checkpointing in MirrorMaker

Hi, One more update. As I was working on the PR, I realized that the only way to support IdentityReplicationPolicy is to add an extra topic filter to the checkpointing. I updated the KIP accordingly. I also opened a draft PR to demonstrate the proposed changes: https://github.com/apache/kafka/pull

Can someone help me review and merge this pull request?

Hello, Everyone Can someone help me review and merge this pull request? Thanks! https://github.com/apache/kafka/pull/17571 KAFKA-17755 AbstractPartitionAssignor can not enable RackAwareAssignm… #17571 Best Regards -Jerry Cai

[jira] [Reopened] (KAFKA-17755) AbstractPartitionAssignor can not enable RackAwareAssignment base on lead rack mode

[ https://issues.apache.org/jira/browse/KAFKA-17755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Harris reopened KAFKA-17755: - > AbstractPartitionAssignor can not enable RackAwareAssignment base on lead > rack mode > -

[jira] [Resolved] (KAFKA-16564) Apply `Xlint` to java code in core module

[ https://issues.apache.org/jira/browse/KAFKA-16564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16564. Fix Version/s: 4.0.0 Resolution: Fixed > Apply `Xlint` to java code in core module

[jira] [Created] (KAFKA-17879) test_performance_services.py should use DEV version to run kafka service

Chia-Ping Tsai created KAFKA-17879: -- Summary: test_performance_services.py should use DEV version to run kafka service Key: KAFKA-17879 URL: https://issues.apache.org/jira/browse/KAFKA-17879 Project:

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.9 #95

See

Re: [VOTE] 3.8.1 RC1

Hi all! Gentle ping on this thread. Thanks! -- Josep Prat Open Source Engineering Director, Aiven josep.p...@aiven.io | +491715557497 | aiven.io Aiven Deutschland GmbH Alexanderufer 3-7, 10117 Berlin Geschäftsführer: Oskari Saarenmaa, Hannu Valtonen, Anna Richardson, Kenneth C

[jira] [Created] (KAFKA-17876) Consider renaming org.apache.kafka.server:type=AssignmentsManager

Mickael Maison created KAFKA-17876: -- Summary: Consider renaming org.apache.kafka.server:type=AssignmentsManager Key: KAFKA-17876 URL: https://issues.apache.org/jira/browse/KAFKA-17876 Project: Kafka

[jira] [Created] (KAFKA-17877) IllegalStateException: missing producer id from the WriteTxnMarkersResponse

Calvin Liu created KAFKA-17877: -- Summary: IllegalStateException: missing producer id from the WriteTxnMarkersResponse Key: KAFKA-17877 URL: https://issues.apache.org/jira/browse/KAFKA-17877 Project: Kafk

[jira] [Resolved] (KAFKA-17868) Do not ignore --feature flag in kafka-storage.sh

[ https://issues.apache.org/jira/browse/KAFKA-17868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin McCabe resolved KAFKA-17868. -- Resolution: Fixed > Do not ignore --feature flag in kafka-storage.sh > ---

Re: [VOTE] 3.9.0 RC3

Hi Luke, Thanks for the docs PR. I pushed some changes to add a better description of static vs. dynamic quorums, and how the user can tell which one they're running. Take a look. best, Colin On Fri, Oct 25, 2024, at 05:27, Luke Chen wrote: > Hi Colin, > > I opened a PR

Re: [VOTE] 3.9.0 RC2

Hi Anton, I appreciate your desire for clarity in the specification. If you think there's something we could do to clarify the docs, let me know (or better yet, file a PR!) But we cannot change the behavior of defaults for tagged fields. The current behavior is older than 3.9 and a lot of thin

Re: [VOTE] 3.9.0 RC2

Hi again Colin, > The implicit defaults have been documented for a long time Yes, if you read my message you will see I am referencing and quoting that exact documentation. The new behavior is clearly excluded by the explicit pre requisite in that exact documentation. Again in summary (all three

[jira] [Created] (KAFKA-17873) Add description to all packages in the public API

Mickael Maison created KAFKA-17873: -- Summary: Add description to all packages in the public API Key: KAFKA-17873 URL: https://issues.apache.org/jira/browse/KAFKA-17873 Project: Kafka Issue T

[jira] [Created] (KAFKA-17878) Move ActionQueue to server module

Dmitry Werner created KAFKA-17878: - Summary: Move ActionQueue to server module Key: KAFKA-17878 URL: https://issues.apache.org/jira/browse/KAFKA-17878 Project: Kafka Issue Type: Sub-task

[DISCUSS] KIP-1091: Improved Kafka Streams operator metrics

Hi All, I would like to start a discussion thread on KIP-1091:Improved Kafka Streams operator metrics Here's a link to the KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-1091%3A+Improved+Kafka+Streams+operator+metrics I look forward to the discussion. Thanks, Bill

Re: [DISCUSS] Apache Kafka 3.7.2 release

Thanks all (and sorry for the delay). I'll go ahead with the release. -- There is one ticket that we might want to cherry-pick back. I did leave comment on the ticket: https://issues.apache.org/jira/browse/KAFKA-17584 If anybody want to chime it, feel free. After cherry-picked (or not, if we

[VOTE] 3.9.0 RC4

This is the fourth candidate for the release of Apache Kafka 3.9.0. I have titled it rc4 since I had an rc1 which got very far, even to the point of pushing tags and docker images, before I spotted an issue. So rather than mutate the tags, I decided to skip over rc1. - This is a major release,

Re: [VOTE] 3.9.0 RC4

Sorry, please ignore this. I failed to include a commit that should have been in here! I will respin this momentarily. best, Colin On Fri, Oct 25, 2024, at 16:57, Colin McCabe wrote: > This is the fourth candidate for the release of Apache Kafka 3.9.0. I > have titled it rc4 since I had an rc1