[jira] [Created] (KAFKA-17282) pollUnattachedAsObserver should not consider electionTimeoutMs

Alyssa Huang created KAFKA-17282: Summary: pollUnattachedAsObserver should not consider electionTimeoutMs Key: KAFKA-17282 URL: https://issues.apache.org/jira/browse/KAFKA-17282 Project: Kafka

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

See

Re: [DISCUSS] KIP-1078: Remove Leaking Getter Methods in Joined Helper Class

Hi Matthias, Thank you for pointing that out. I will keep it in mind. Do I need to update the content of the KIP, or can we leave it as is? Best regards, TengYao Matthias J. Sax 於 2024年8月7日 週三 上午10:45寫道： > I have already an open PR for the internal cleanup: > https://github.com/apache/kafka/pul

Re: [DISCUSS] KIP-1078: Remove Leaking Getter Methods in Joined Helper Class

I have already an open PR for the internal cleanup: https://github.com/apache/kafka/pull/14551 While I did this cleanup, I filed the Jira for the necessary public changes. Did not expect that the KIP would get picked up so quickly :) In general, a KIP should only concern itself with public AP

[jira] [Created] (KAFKA-17281) Remove old PAPI methods

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

[jira] [Created] (KAFKA-17280) Remove deprecated methods from DeserializationExceptionHandler as ProductionExceptionHandler

Matthias J. Sax created KAFKA-17280: --- Summary: Remove deprecated methods from DeserializationExceptionHandler as ProductionExceptionHandler Key: KAFKA-17280 URL: https://issues.apache.org/jira/browse/KAFKA-17280

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #3176

See

[jira] [Created] (KAFKA-17279) Handle retriable errors from offset fetches in ConsumerCoordinator

Sean Quah created KAFKA-17279: - Summary: Handle retriable errors from offset fetches in ConsumerCoordinator Key: KAFKA-17279 URL: https://issues.apache.org/jira/browse/KAFKA-17279 Project: Kafka

[jira] [Resolved] (KAFKA-12828) Remove Deprecated methods under KeyQueryMetadata

[ https://issues.apache.org/jira/browse/KAFKA-12828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12828. - Resolution: Fixed > Remove Deprecated methods under KeyQueryMetadata > -

[jira] [Created] (KAFKA-17278) Figure out and fix why the RPC version tests in KafkaRaftClientTest didn't catch a bug in the Fetch schema

José Armando García Sancio created KAFKA-17278: -- Summary: Figure out and fix why the RPC version tests in KafkaRaftClientTest didn't catch a bug in the Fetch schema Key: KAFKA-17278 URL: https://issue

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.8 #80

See

[jira] [Created] (KAFKA-17277) KIP-1022 : Add version mapping and feature dependencies commands to tools

Ritika Reddy created KAFKA-17277: Summary: KIP-1022 : Add version mapping and feature dependencies commands to tools Key: KAFKA-17277 URL: https://issues.apache.org/jira/browse/KAFKA-17277 Project: Ka

Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.9 #21

See

[jira] [Created] (KAFKA-17276) KRaft client should reser the replicaDirectoryId if the version is smaller than 17

Chia-Ping Tsai created KAFKA-17276: -- Summary: KRaft client should reser the replicaDirectoryId if the version is smaller than 17 Key: KAFKA-17276 URL: https://issues.apache.org/jira/browse/KAFKA-17276

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #3175

See

[jira] [Resolved] (KAFKA-15935) Flaky test: testRestartReplication() – org.apache.kafka.connect.mirror.integration.IdentityReplicationIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-15935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-15935. --- Fix Version/s: 4.0.0 Resolution: Fixed > Flaky test: testRestartReplication() – > or

[jira] [Resolved] (KAFKA-16919) Flaky test testNoCheckpointsIfNoRecordsAreMirrored() – org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest

[ https://issues.apache.org/jira/browse/KAFKA-16919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-16919. --- Fix Version/s: 4.0.0 Resolution: Fixed > Flaky test testNoCheckpointsIfNoRecordsAreM

[jira] [Resolved] (KAFKA-15933) Flaky test: testRestartReplication() – org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationTransactionsTest

[ https://issues.apache.org/jira/browse/KAFKA-15933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-15933. --- Fix Version/s: 4.0.0 Resolution: Fixed > Flaky test: testRestartReplication() – > or

[jira] [Resolved] (KAFKA-10812) Unclean worker shutdown in MirrorConnectorsIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-10812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-10812. --- Fix Version/s: 4.0.0 Resolution: Fixed > Unclean worker shutdown in MirrorConnectorsI

[jira] [Resolved] (KAFKA-15524) Flaky test org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.testResetSinkConnectorOffsetsZombieSinkTasks

[ https://issues.apache.org/jira/browse/KAFKA-15524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-15524. --- Fix Version/s: 4.0.0 Resolution: Fixed > Flaky test > org.apache.kafka.connect.integ

[jira] [Resolved] (KAFKA-15892) Flaky test: testAlterSinkConnectorOffsets – org.apache.kafka.connect.integration.OffsetsApiIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-15892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-15892. --- Fix Version/s: 4.0.0 Resolution: Fixed > Flaky test: testAlterSinkConnectorOffsets –

[jira] [Resolved] (KAFKA-15914) Flaky test - testAlterSinkConnectorOffsetsOverriddenConsumerGroupId - OffsetsApiIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-15914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-15914. --- Fix Version/s: 4.0.0 Resolution: Fixed > Flaky test - testAlterSinkConnectorOffsetsOv

[jira] [Resolved] (KAFKA-15918) Flaky test - OffsetsApiIntegrationTest.testResetSinkConnectorOffsets

[ https://issues.apache.org/jira/browse/KAFKA-15918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-15918. --- Fix Version/s: 4.0.0 Resolution: Fixed > Flaky test - OffsetsApiIntegrationTest.testR

[jira] [Resolved] (KAFKA-15197) Flaky test MirrorConnectorsIntegrationExactlyOnceTest.testOffsetTranslationBehindReplicationFlow()

[ https://issues.apache.org/jira/browse/KAFKA-15197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-15197. --- Fix Version/s: 4.0.0 (was: 3.9.0) Resolution: Fixed > Flaky te

[jira] [Resolved] (KAFKA-15292) Flaky test IdentityReplicationIntegrationTest#testReplicateSourceDefault()

[ https://issues.apache.org/jira/browse/KAFKA-15292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-15292. --- Fix Version/s: 4.0.0 Resolution: Fixed > Flaky test IdentityReplicationIntegrationTes

[jira] [Resolved] (KAFKA-15072) Flaky test MirrorConnectorsIntegrationExactlyOnceTest.testReplicationWithEmptyPartition

[ https://issues.apache.org/jira/browse/KAFKA-15072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-15072. --- Fix Version/s: 4.0.0 Resolution: Fixed > Flaky test > MirrorConnectorsIntegrationExa

[jira] [Resolved] (KAFKA-14453) Flaky test suite MirrorConnectorsWithCustomForwardingAdminIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-14453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14453. --- Fix Version/s: 4.0.0 Resolution: Fixed > Flaky test suite MirrorConnectorsWithCustomF

[jira] [Resolved] (KAFKA-15945) Flaky test - testSyncTopicConfigs() – org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationBaseTest

[ https://issues.apache.org/jira/browse/KAFKA-15945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-15945. --- Fix Version/s: 4.0.0 Resolution: Fixed > Flaky test - testSyncTopicConfigs() – > org

[jira] [Created] (KAFKA-17275) Move ReplicatedCounter to test scope

Chia-Ping Tsai created KAFKA-17275: -- Summary: Move ReplicatedCounter to test scope Key: KAFKA-17275 URL: https://issues.apache.org/jira/browse/KAFKA-17275 Project: Kafka Issue Type: Improvem

[jira] [Resolved] (KAFKA-17222) Remove the subclass of KafkaMetricsGroup

[ https://issues.apache.org/jira/browse/KAFKA-17222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17222. Fix Version/s: 4.0.0 Resolution: Fixed > Remove the subclass of KafkaMetricsGroup >

Re: Re: [DISCUSS] KIP-1074: Make the replication of internal topics configurable

Hi Viktor, Nice to hear from you! My thoughts: 1. I initially liked this idea, but it doesn't seem like the costs to all existing users outweigh the benefits that would be reaped by just a few. This is possibly because I'm assuming the upgrade path would be pretty gnarly, though; if we can make i

[jira] [Resolved] (KAFKA-15896) Flaky test: shouldQuerySpecificStalePartitionStores() – org.apache.kafka.streams.integration.StoreQueryIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-15896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-15896. - Resolution: Cannot Reproduce > Flaky test: shouldQuerySpecificStalePartitionStores() –

[jira] [Resolved] (KAFKA-17254) Kafka Server/CLI no longer respects log4j.properties/tools-log4j.properties file

[ https://issues.apache.org/jira/browse/KAFKA-17254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krishna V Reddy resolved KAFKA-17254. - Assignee: Krishna V Reddy Resolution: Not A Problem > Kafka Server/CLI no longer r

[jira] [Created] (KAFKA-17274) Remove deprecate `TransactionLogMessageFormatter`, GroupMetadataMessageFormatter` and `OffsetsMessageFormatter`

黃竣陽 created KAFKA-17274: --- Summary: Remove deprecate `TransactionLogMessageFormatter`, GroupMetadataMessageFormatter` and `OffsetsMessageFormatter` Key: KAFKA-17274 URL: https://issues.apache.org/jira/browse/KAFKA-17274

[jira] [Created] (KAFKA-17273) Migrate BootstrapControllersIntegrationTest to use ClusterTestExtention

Chia-Ping Tsai created KAFKA-17273: -- Summary: Migrate BootstrapControllersIntegrationTest to use ClusterTestExtention Key: KAFKA-17273 URL: https://issues.apache.org/jira/browse/KAFKA-17273 Project:

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

Dongnuo Lyu created KAFKA-17272: --- Summary: System tests for protocol migration Key: KAFKA-17272 URL: https://issues.apache.org/jira/browse/KAFKA-17272 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-16745) Add support for share fetch request in KafkaApis

[ https://issues.apache.org/jira/browse/KAFKA-16745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-16745. - Fix Version/s: 4.0.0 Resolution: Fixed Merged the PR to trunk. > Add support for share fetch req

[jira] [Created] (KAFKA-17271) Refactor the section "Reverting to ZooKeeper mode During the Migration"

Chia-Ping Tsai created KAFKA-17271: -- Summary: Refactor the section "Reverting to ZooKeeper mode During the Migration" Key: KAFKA-17271 URL: https://issues.apache.org/jira/browse/KAFKA-17271 Project:

Re: [PR] KAFKA-17146 Include note to remove migration znode [kafka-site]

chia7712 commented on code in PR #620: URL: https://github.com/apache/kafka-site/pull/620#discussion_r1705673008 ## 38/ops.html: ## @@ -4105,7 +4105,10 @@ Reverting to ZooKeeper mode During the Migration Using zookeeper-shell.sh, run rm

[jira] [Created] (KAFKA-17270) the input function of Exit#setHaltProcedure/Exit#setExitProcedure should return `Unit` rather than `Nothing`

Chia-Ping Tsai created KAFKA-17270: -- Summary: the input function of Exit#setHaltProcedure/Exit#setExitProcedure should return `Unit` rather than `Nothing` Key: KAFKA-17270 URL: https://issues.apache.org/jira/bro

Re: [PR] KAFKA-17146 Include note to remove migration znode [kafka-site]

chia7712 commented on code in PR #620: URL: https://github.com/apache/kafka-site/pull/620#discussion_r1705624608 ## 38/ops.html: ## @@ -4105,7 +4105,10 @@ Reverting to ZooKeeper mode During the Migration Using zookeeper-shell.sh, run rm

[jira] [Resolved] (KAFKA-4400) Prefix for sink task consumer groups should be configurable

[ https://issues.apache.org/jira/browse/KAFKA-4400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-4400. -- Resolution: Won't Do > Prefix for sink task consumer groups should be configurable > --

[jira] [Resolved] (KAFKA-15330) Migration from ZK to KRaft works with 3.4 but fails from 3.5 upwards

[ https://issues.apache.org/jira/browse/KAFKA-15330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur resolved KAFKA-15330. -- Resolution: Won't Fix Closing since it is not recommended to perform a migration on 3.4 or 3.5

Re: [PR] KAFKA-17146 Include note to remove migration znode [kafka-site]

mumrah commented on code in PR #620: URL: https://github.com/apache/kafka-site/pull/620#discussion_r1705552076 ## 38/ops.html: ## @@ -4105,7 +4105,10 @@ Reverting to ZooKeeper mode During the Migration Using zookeeper-shell.sh, run rmr

Re: [DISCUSS] KIP-1071: Streams Rebalance Protocol

Hi Lianet and Andrew, LM1/LM2: You are right. The idea is to omit fields exactly in the same situations as in KIP-848. In the KIP, I stuck with how the behavior was defined in KIP-848 (e.g. KIP-848 defined that that instance ID will be omitted if it did not change since the last heartbeat). But yo

[jira] [Resolved] (KAFKA-17262) kafka-topics.sh usage message is confusing

[ https://issues.apache.org/jira/browse/KAFKA-17262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17262. Resolution: Fixed > kafka-topics.sh usage message is confusing > -

[jira] [Created] (KAFKA-17269) Fix ConcurrentModificationException caused by NioEchoServer.closeNewChannels

Chia-Ping Tsai created KAFKA-17269: -- Summary: Fix ConcurrentModificationException caused by NioEchoServer.closeNewChannels Key: KAFKA-17269 URL: https://issues.apache.org/jira/browse/KAFKA-17269 Proj

Re: [PR] MINOR: Update docs, remove JBOD from missing features [kafka-site]

soarez merged PR #622: URL: https://github.com/apache/kafka-site/pull/622 -- 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.o

Re: Re: [DISCUSS] KIP-1074: Make the replication of internal topics configurable

Hi all, I think there are a couple of other alternatives to discuss. 1. We may just simply change the internal topic naming to something like "mm2internal" and provide upgrade functionality as well. In this scenario we wouldn't need to tinker with the prefixes or the naming patterns, we just simp