[jira] [Created] (KAFKA-17859) Bug

thanhnd1996 created KAFKA-17859: --- Summary: Bug Key: KAFKA-17859 URL: https://issues.apache.org/jira/browse/KAFKA-17859 Project: Kafka Issue Type: Bug Components: controller Affect

[jira] [Created] (KAFKA-17858) Remove ZK-related configuration from the log4j configuration.

TengYao Chi created KAFKA-17858: --- Summary: Remove ZK-related configuration from the log4j configuration. Key: KAFKA-17858 URL: https://issues.apache.org/jira/browse/KAFKA-17858 Project: Kafka

doc clarification about meesage format

Hi all, I am reading official doc here: https://kafka.apache.org/documentation/#messageformat, and I could not fully understand it. If someone can clarify it for me, it would be much appreciated. The sentence is The partition leader epoch field is not included in the CRC computation to avoid the

Jenkins build is back to stable : Kafka » Kafka PowerPC Daily » test-powerpc #95

See

[jira] [Created] (KAFKA-17857) Move AbstractResetIntegrationTest and subclasses to tools

Greg Harris created KAFKA-17857: --- Summary: Move AbstractResetIntegrationTest and subclasses to tools Key: KAFKA-17857 URL: https://issues.apache.org/jira/browse/KAFKA-17857 Project: Kafka Issue

Re: [VOTE] KIP-891: Running multiple versions of Connector plugins

Hi all, Bumping this thread in advance of the November 20th KIP freeze for 4.0. Thanks! Greg On Tue, Oct 8, 2024 at 5:03 AM Snehashis wrote: > Thanks Greg, Chris and Ashwin > > For the individual queries, > > 1. The example is incorrect and both should be treated as exact versions. > Thanks fo

[jira] [Resolved] (KAFKA-17114) DefaultStateUpdater::handleRuntimeException should update isRunning before calling `addToExceptionsAndFailedTasksThenClearUpdatingAndPausedTasks`

[ https://issues.apache.org/jira/browse/KAFKA-17114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-17114. - Resolution: Cannot Reproduce We did push some fixed for related tickets. Closing this fo

[jira] [Reopened] (KAFKA-9323) Refactor Streams' upgrade system tests

[ https://issues.apache.org/jira/browse/KAFKA-9323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-9323: > Refactor Streams' upgrade system tests > --- > >

[jira] [Resolved] (KAFKA-9323) Refactor Streams' upgrade system tests

[ https://issues.apache.org/jira/browse/KAFKA-9323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9323. Resolution: Fixed > Refactor Streams' upgrade system tests > -

Re: [VOTE] 3.9.0 RC3

Hi Colin, Thanks for running the release. I did the following verification steps: 1. Built from source 2. Validated all checksums 3. Ran all the unit tests 4. Pulled both docker images and started up Kafka 5. Ran the KRaft quick start 6. Ran the ZK quick start 7. Ran the Kaf

[jira] [Resolved] (KAFKA-17402) Test failure: DefaultStateUpdaterTest.shouldGetTasksFromRestoredActiveTasks expected: <2> but was: <3>

[ https://issues.apache.org/jira/browse/KAFKA-17402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-17402. - Resolution: Cannot Reproduce We did put out some fixes for related tickets. Closing this

[jira] [Created] (KAFKA-17856) Move ConfigCommandTest and ConfigCommandIntegrationTest to tool module

Chia-Ping Tsai created KAFKA-17856: -- Summary: Move ConfigCommandTest and ConfigCommandIntegrationTest to tool module Key: KAFKA-17856 URL: https://issues.apache.org/jira/browse/KAFKA-17856 Project: K

[jira] [Resolved] (KAFKA-17526) make ConfigCommandIntegrationTest.java test use correct arguments in testing alias

[ https://issues.apache.org/jira/browse/KAFKA-17526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17526. Fix Version/s: 4.0.0 Resolution: Fixed > make ConfigCommandIntegrationTest.java tes

[jira] [Resolved] (KAFKA-17813) Create server connection id class encapsulating functionality for generation

[ https://issues.apache.org/jira/browse/KAFKA-17813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-17813. - Fix Version/s: 4.0.0 Resolution: Fixed merged the PR to trunk > Create server connection id clas

[jira] [Created] (KAFKA-17855) Improve documentation for transactions in the light of KIP-1050

Andrew Schofield created KAFKA-17855: Summary: Improve documentation for transactions in the light of KIP-1050 Key: KAFKA-17855 URL: https://issues.apache.org/jira/browse/KAFKA-17855 Project: Kafk

[jira] [Created] (KAFKA-17854) add tests for `ReadOnlyWindowStoreStub#fetch(null, null ...)`

Chia-Ping Tsai created KAFKA-17854: -- Summary: add tests for `ReadOnlyWindowStoreStub#fetch(null, null ...)` Key: KAFKA-17854 URL: https://issues.apache.org/jira/browse/KAFKA-17854 Project: Kafka

[jira] [Reopened] (KAFKA-15284) Implement ConsumerGroupProtocolVersionResolver to determine consumer group protocol

[ https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True reopened KAFKA-15284: --- Assignee: Kirk True > Implement ConsumerGroupProtocolVersionResolver to determine consumer group

[jira] [Resolved] (KAFKA-17844) Add tests and fix to complete share fetch request on exception from manager

[ https://issues.apache.org/jira/browse/KAFKA-17844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-17844. --- Resolution: Fixed > Add tests and fix to complete share fetch request on exception from mana

[jira] [Created] (KAFKA-17853) Console share consumer is not terminated immediately

Apoorv Mittal created KAFKA-17853: - Summary: Console share consumer is not terminated immediately Key: KAFKA-17853 URL: https://issues.apache.org/jira/browse/KAFKA-17853 Project: Kafka Issue

Re: Cluster ID starting with hyphen, docs not exactly in sync

Hi Samuli, Cluster ID is allowed to start with a hyphen. But you must pass it to the kafka-storage format command line like this: > kafka-storage.sh format --cluster-id=$MY_CLUSTER_ID ... Note the equals sign. We didn't want people to have to deal with this, which is why we made generate-uuid

[jira] [Resolved] (KAFKA-17272) System tests for protocol migration

[ https://issues.apache.org/jira/browse/KAFKA-17272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-17272. - Fix Version/s: 4.0.0 Resolution: Fixed > System tests for protocol migration > --

[jira] [Created] (KAFKA-17852) Add help message to the --ignore-formatted flag of StorageTool

Mickael Maison created KAFKA-17852: -- Summary: Add help message to the --ignore-formatted flag of StorageTool Key: KAFKA-17852 URL: https://issues.apache.org/jira/browse/KAFKA-17852 Project: Kafka

Re: [DISCUSS] KIP-1043: Administration of groups

Hi David, Thanks for your response. I really don't like an API response whose error message is a significant part of the interface. If we have code that checks for specific error messages and takes different actions, we've got it wrong. If we are just displaying the error text or adding it to an e

Cluster ID starting with hyphen, docs not exactly in sync

Hi! Thank you for the Apache Kafka! We are grateful for it. In our root cause analysis process discussions, we were asked to share following piece of information to the Apache Kafka community. Following is a known topic, in generic, it seems, already. E.g. there are existing tickets, and Uuid.ja

Re: [VOTE] 3.9.0 RC3

Hi, I did the following tests: - Ran all unit and integration tests - Spot checked the documentation - Tried out new Maven dependencies - Tested KIP-853, KIP-950, KIP-956 and KIP-1057 +1 (non binding) Thanks Fede On Mon, Oct 21, 2024 at 11:12 PM Colin McCabe wrote: > > This is the third candi

[jira] [Created] (KAFKA-17851) Save internal topic to a separate kafka cluster

Zhijian Chen created KAFKA-17851: Summary: Save internal topic to a separate kafka cluster Key: KAFKA-17851 URL: https://issues.apache.org/jira/browse/KAFKA-17851 Project: Kafka Issue Type: I

[jira] [Created] (KAFKA-17850) Stop leaking internal exception to StreamsUncaughtExceptionHandler

Bruno Cadonna created KAFKA-17850: - Summary: Stop leaking internal exception to StreamsUncaughtExceptionHandler Key: KAFKA-17850 URL: https://issues.apache.org/jira/browse/KAFKA-17850 Project: Kafka

[jira] [Created] (KAFKA-17849) Remove UnsupportedOperationException in MockController

TaiJuWu created KAFKA-17849: --- Summary: Remove UnsupportedOperationException in MockController Key: KAFKA-17849 URL: https://issues.apache.org/jira/browse/KAFKA-17849 Project: Kafka Issue Type: Te

Re: [DISCUSS] KIP-1043: Administration of groups

Hi Andrew, Please excuse me for my delayed response. Thanks for the update. Overall, I am fine with the KIP, except for the INCONSISTENT_GROUP_TYPE error. We have three methods to describe groups: 1) Admin#describeClassicGroup (added by the KIP) 2) Admin#describeConsumerGroup 3) Admin#describeSha

Save internal topic to a separate kafka cluster

Hi, Save internal topic to a separate kafka cluster For the mm2-offset-syncs topic there is a parameter to control its storage cluster: offset-syncs.topic.location, but this parameter can only control whether it is in the source or target cluster. For checkpoints topic and heartbeat topic, th