jira
Thread
Date
Earlier messages
Messages by Thread
[PR] KAFKA-16922 : Adding unit tests for NewTopic [kafka]
via GitHub
Re: [PR] KAFKA-16922 : Adding unit tests for NewTopic [kafka]
via GitHub
[PR] KAFKA-15623: Migrate streams tests (part 1) module to JUnit 5 [kafka]
via GitHub
[jira] [Assigned] (KAFKA-16922) add unit test for NewTopic
Muralidhar Basani (Jira)
[jira] [Commented] (KAFKA-16903) Task should consider producer error previously occurred for different task
A. Sophie Blee-Goldman (Jira)
Re: [PR] KAFKA-15045: (KIP-924 pt. 20) Custom task assignment configuration fix [kafka]
via GitHub
Re: [PR] KAFKA-15045: (KIP-924 pt. 20) Custom task assignment configuration fix [kafka]
via GitHub
Re: [PR] KAFKA-15045: (KIP-924 pt. 20) Custom task assignment configuration fix [kafka]
via GitHub
Re: [PR] KAFKA-16921: Migrate all junit 4 code to junit 5 for connect module [kafka]
via GitHub
Re: [PR] KAFKA-16921: Migrate all junit 4 code to junit 5 for connect module [kafka]
via GitHub
Re: [PR] KAFKA-16921: Migrate all junit 4 code to junit 5 for connect module [kafka]
via GitHub
Re: [PR] KAFKA-16921: Migrate all junit 4 code to junit 5 for connect module [kafka]
via GitHub
Re: [PR] KAFKA-16921: Migrate all junit 4 code to junit 5 for connect module [kafka]
via GitHub
Re: [PR] KAFKA-16921: Migrate all junit 4 code to junit 5 for connect module [kafka]
via GitHub
[jira] [Updated] (KAFKA-16921) Migrate all junit 4 code to junit 5 for connect module
Chia-Ping Tsai (Jira)
Re: [PR] KAFKA-16921: Migrate all junit 4 assert to junit 5 for connect module [kafka]
via GitHub
[jira] [Updated] (KAFKA-16921) Migrate all junit 4 assert to junit 5 for connect module
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-16921) Migrate all junit 4 assert to junit 5 for connect module
Chia-Ping Tsai (Jira)
[jira] [Assigned] (KAFKA-15623) Migrate remaining tests in streams module to JUnit 5
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-16921) Migrate all junit 4 assert to junit 5 for connect module
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-12199) Migrate connect:runtime module to JUnit 5
Hector Geraldino (Jira)
[jira] [Commented] (KAFKA-12199) Migrate connect:runtime module to JUnit 5
Hector Geraldino (Jira)
[jira] [Commented] (KAFKA-16922) add unit test for NewTopic
Muralidhar Basani (Jira)
[jira] [Commented] (KAFKA-16922) add unit test for NewTopic
Chia-Ping Tsai (Jira)
[jira] [Assigned] (KAFKA-10787) Introduce an import order in Java sources
Chia-Ping Tsai (Jira)
[jira] [Assigned] (KAFKA-12572) Add import ordering checkstyle rule and configure an automatic formatter
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-10787) Introduce an import order in Java sources
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-16922) add unit test for NewTopic
Chia-Ping Tsai (Jira)
Re: [PR] KAFKA-16921: Migrate all junit 4 assert to junit 5 in connect module [kafka]
via GitHub
Re: [PR] KAFKA-16921: Migrate all junit 4 assert to junit 5 in connect module [kafka]
via GitHub
[jira] [Resolved] (KAFKA-7438) Replace EasyMock and PowerMock with Mockito
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-16921) Migrate all junit 4 assert to junit 5
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-16921) Migrate all junit 4 assert to junit 5
Jira
[jira] [Resolved] (KAFKA-14132) Remaining PowerMock to Mockito tests
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-16878) Remove powermock and easymock from code base
Chia-Ping Tsai (Jira)
[jira] (KAFKA-16893) ConnectorUtils can group elements in round-robin fashion
Fan Yang (Jira)
[PR] KAFKA-16920: close BrokerLifecycleManager in tests [kafka]
via GitHub
Re: [PR] KAFKA-16920: close BrokerLifecycleManager in tests [kafka]
via GitHub
Re: [PR] KAFKA-16920: close BrokerLifecycleManager in tests [kafka]
via GitHub
[jira] [Updated] (KAFKA-16667) KRaftMigrationDriver gets stuck after successive failovers
Igor Soarez (Jira)
[jira] [Assigned] (KAFKA-16920) Flaky test testControlledShutdown() - kafka.server.BrokerLifecycleManagerTest
Gaurav Narula (Jira)
[jira] [Commented] (KAFKA-16667) KRaftMigrationDriver gets stuck after successive failovers
Igor Soarez (Jira)
[jira] [Commented] (KAFKA-16667) KRaftMigrationDriver gets stuck after successive failovers
Igor Soarez (Jira)
[jira] [Commented] (KAFKA-8115) Flaky Test CoordinatorTest#testTaskRequestWithOldStartMsGetsUpdated
Igor Soarez (Jira)
[jira] [Commented] (KAFKA-15789) Flaky Test - testTimeouts - QuorumControllerTest
Igor Soarez (Jira)
[jira] [Commented] (KAFKA-16402) Flaky test org.apache.kafka.controller.QuorumControllerTest.testSnapshotSaveAndLoad
Igor Soarez (Jira)
[jira] [Updated] (KAFKA-16383) fix flaky test IdentityReplicationIntegrationTest.testReplicateFromLatest()
Igor Soarez (Jira)
[jira] [Commented] (KAFKA-16383) fix flaky test IdentityReplicationIntegrationTest.testReplicateFromLatest()
Igor Soarez (Jira)
[jira] [Commented] (KAFKA-15197) Flaky test MirrorConnectorsIntegrationExactlyOnceTest.testOffsetTranslationBehindReplicationFlow()
Igor Soarez (Jira)
[jira] [Commented] (KAFKA-15963) Flaky test: testBrokerHeartbeatDuringMigration [3] 3.6-IV0 – org.apache.kafka.controller.QuorumControllerTest
Igor Soarez (Jira)
[jira] [Updated] (KAFKA-16920) Flaky test testControlledShutdown() - kafka.server.BrokerLifecycleManagerTest
Igor Soarez (Jira)
[jira] [Updated] (KAFKA-16920) Flaky test testControlledShutdown() - kafka.server.BrokerLifecycleManagerTest
Igor Soarez (Jira)
[jira] [Created] (KAFKA-16920) Flaky test testControlledShutdown() - kafka.server.BrokerLifecycleManagerTest
Igor Soarez (Jira)
[jira] [Created] (KAFKA-16919) Flaky test testNoCheckpointsIfNoRecordsAreMirrored() – org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationSSLTest
Igor Soarez (Jira)
[jira] [Commented] (KAFKA-15914) Flaky test - testAlterSinkConnectorOffsetsOverriddenConsumerGroupId - OffsetsApiIntegrationTest
Igor Soarez (Jira)
[jira] [Commented] (KAFKA-15961) Flaky test: testTopicIdPersistsThroughControllerRestart() – kafka.controller.ControllerIntegrationTest
Igor Soarez (Jira)
[jira] [Assigned] (KAFKA-16918) TestUtils#assertFutureThrows should use future.get with timeout
Luke Chen (Jira)
[jira] [Commented] (KAFKA-16918) TestUtils#assertFutureThrows should use future.get with timeout
Chia Chuan Yu (Jira)
[jira] [Commented] (KAFKA-16918) TestUtils#assertFutureThrows should use future.get with timeout
Luke Chen (Jira)
[jira] [Assigned] (KAFKA-16863) Consider removing `default.` prefix for exception handler config
Muralidhar Basani (Jira)
[jira] [Created] (KAFKA-16918) TestUtils#assertFutureThrows should use future.get with timeout
Luke Chen (Jira)
[PR] MINOR: Fix broken ReassignPartitionsCommandTest test [kafka]
via GitHub
Re: [PR] MINOR: Fix broken ReassignPartitionsCommandTest test [kafka]
via GitHub
Re: [PR] MINOR: Fix broken ReassignPartitionsCommandTest test [kafka]
via GitHub
[jira] [Resolved] (KAFKA-16916) ClientAuthenticationFailureTest.testAdminClientWithInvalidCredentials will run forever
Luke Chen (Jira)
[PR] KAFKA-16917: Align the returned Map type of KafkaAdminClient [kafka]
via GitHub
Re: [PR] KAFKA-16917: Align the returned Map type of KafkaAdminClient [kafka]
via GitHub
Re: [PR] KAFKA-16917: Align the returned Map type of KafkaAdminClient [kafka]
via GitHub
Re: [PR] KAFKA-16917: Align the returned Map type of KafkaAdminClient [kafka]
via GitHub
Re: [PR] KAFKA-16917: Align the returned Map type of KafkaAdminClient [kafka]
via GitHub
Re: [PR] KAFKA-16917: Align the returned Map type of KafkaAdminClient [kafka]
via GitHub
Re: [PR] KAFKA-16917: Align the returned Map type of KafkaAdminClient [kafka]
via GitHub
[jira] [Assigned] (KAFKA-16917) Align the returned map type of KafkaAdminClient
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-16917) Align the returned map type of KafkaAdminClient
TengYao Chi (Jira)
[jira] [Created] (KAFKA-16917) Align the returned map type of KafkaAdminClient
Chia-Ping Tsai (Jira)
Re: [PR] KAFKA-16348 [WIP]: add logs to observe [kafka]
via GitHub
Re: [PR] Fix documentation for RETRIES_DOC on version 3.2 [kafka]
via GitHub
[jira] [Assigned] (KAFKA-16916) ClientAuthenticationFailureTest.testAdminClientWithInvalidCredentials will run forever
Haruki Okada (Jira)
[PR] KAFKA-16916: Fixing error in completing future [kafka]
via GitHub
Re: [PR] KAFKA-16916: Fixing error in completing future [kafka]
via GitHub
Re: [PR] KAFKA-16916: Fixing error in completing future [kafka]
via GitHub
Re: [PR] KAFKA-16916: Fixing error in completing future [kafka]
via GitHub
[jira] [Updated] (KAFKA-16916) ClientAuthenticationFailureTest.testAdminClientWithInvalidCredentials will run forever
A. Sophie Blee-Goldman (Jira)
[jira] [Updated] (KAFKA-16916) ClientAuthenticationFailureTest.testAdminClientWithInvalidCredentials will run forever
A. Sophie Blee-Goldman (Jira)
[jira] [Updated] (KAFKA-16916) ClientAuthenticationFailureTest.testAdminClientWithInvalidCredentials will run forever
Luke Chen (Jira)
[PR] KAFKA-16916: Disable blocking test temporarily [kafka]
via GitHub
Re: [PR] KAFKA-16916: Disable blocking test temporarily [kafka]
via GitHub
Re: [PR] KAFKA-16916: Disable blocking test temporarily [kafka]
via GitHub
Re: [PR] KAFKA-16916: Disable blocking test temporarily [kafka]
via GitHub
Re: [PR] KAFKA-16916: Disable blocking test temporarily [kafka]
via GitHub
[jira] [Commented] (KAFKA-16916) ClientAuthenticationFailureTest.testAdminClientWithInvalidCredentials will run forever
Luke Chen (Jira)
[jira] [Commented] (KAFKA-16916) ClientAuthenticationFailureTest.testAdminClientWithInvalidCredentials will run forever
Haruki Okada (Jira)
[jira] [Created] (KAFKA-16916) ClientAuthenticationFailureTest.testAdminClientWithInvalidCredentials will run forever
Luke Chen (Jira)
[jira] [Updated] (KAFKA-16536) Use BeginQuorumEpoch as the leader's heartbeat
Jira
[jira] [Updated] (KAFKA-16536) Use BeginQuorumEpoch as the leader's heartbeat
Jira
[PR] MINOR: Update docs for for KIP-671 [kafka]
via GitHub
Re: [PR] MINOR: Update docs for for KIP-671 [kafka]
via GitHub
Re: [PR] MINOR: Update docs for for KIP-671 [kafka]
via GitHub
Re: [PR] MINOR: Update docs for for KIP-671 [kafka]
via GitHub
[jira] [Updated] (KAFKA-12651) Connect should register REST extensions before REST resources
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-12383) Get RaftClusterTest.java and other KIP-500 junit tests working
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-14200) kafka-features.sh must exit with non-zero error code on error
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-14187) kafka-features.sh: add support for --metadata
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-14197) Kraft broker fails to startup after topic creation failure
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-14195) Fix KRaft AlterConfig policy usage for Legacy/Full case
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-14051) KRaft remote controllers do not create metrics reporters
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-14214) StandardAuthorizer may transiently process ACLs out of write order
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-14328) KafkaAdminClient should be Changing the exception level When an exception occurs
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-16300) Wrong documentation for producer config retries
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-15063) Throttle number of active PIDs
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-14250) Exception during normal operation in MirrorSourceTask causes the task to fail instead of shutting down gracefully
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-14571) ZkMetadataCache.getClusterMetadata is missing rack information in aliveNodes
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-13755) Broker heartbeat event should have deadline
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-13902) Support online metadata.version upgrades for KIP-704 in KRaft
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-14275) KRaft Controllers should crash after failing to apply any metadata record
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-14062) OAuth client token refresh fails with SASL extensions
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-14062) OAuth client token refresh fails with SASL extensions
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-13850) kafka-metadata-shell is missing some record types
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-13943) Fix flaky test QuorumControllerTest.testMissingInMemorySnapshot()
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-13858) Kraft should not shutdown metadata listener until controller shutdown is finished
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-13649) StandardAuthorizer should not finish loading until it is ready
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-14217) app-reset-tool.html should remove reference to --zookeeper flag that no longer exists
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-14217) app-reset-tool.html should remove reference to --zookeeper flag that no longer exists
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-14216) Remove ZK reference from org.apache.kafka.server.quota.ClientQuotaCallback javadoc
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-14216) Remove ZK reference from org.apache.kafka.server.quota.ClientQuotaCallback javadoc
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-14170) KRaft Controller: Possible NPE when we remove topics with any offline partitions in the cluster
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-14170) KRaft Controller: Possible NPE when we remove topics with any offline partitions in the cluster
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-14215) KRaft forwarded requests have no quota enforcement
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-14215) KRaft forwarded requests have no quota enforcement
Matthias J. Sax (Jira)
[jira] [Resolved] (KAFKA-16911) Kafka Streams topology optimization docs incomplete
Matthias J. Sax (Jira)
[jira] [Assigned] (KAFKA-16911) Kafka Streams topology optimization docs incomplete
Matthias J. Sax (Jira)
[PR] MINOR: Update docs for KIP-862 [kafka]
via GitHub
Re: [PR] KAFKA-16911: Update docs for KIP-862 [kafka]
via GitHub
Re: [PR] KAFKA-16911: Update docs for KIP-862 [kafka]
via GitHub
[jira] [Assigned] (KAFKA-16899) Rename MembershipManagerImpl's rebalanceTimeoutMs for clarity
Linu Shibu (Jira)
[PR] KAFKA-16897: Move OffsetIndexTest and OffsetMapTest to storage module [kafka]
via GitHub
Re: [PR] KAFKA-16897: Move OffsetIndexTest and OffsetMapTest to storage module [kafka]
via GitHub
Re: [PR] KAFKA-16897: Move OffsetIndexTest and OffsetMapTest to storage module [kafka]
via GitHub
Re: [PR] KAFKA-16897: Move OffsetIndexTest and OffsetMapTest to storage module [kafka]
via GitHub
Re: [PR] KAFKA-16897: Move OffsetIndexTest and OffsetMapTest to storage module [kafka]
via GitHub
Re: [PR] KAFKA-16897: Move OffsetIndexTest and OffsetMapTest to storage module [kafka]
via GitHub
Re: [PR] KAFKA-16897: Move OffsetIndexTest and OffsetMapTest to storage module [kafka]
via GitHub
Re: [PR] KAFKA-16897: Move OffsetIndexTest and OffsetMapTest to storage module [kafka]
via GitHub
Re: [PR] KAFKA-16897: Move OffsetIndexTest and OffsetMapTest to storage module [kafka]
via GitHub
Re: [PR] KAFKA-16897: Move OffsetIndexTest and OffsetMapTest to storage module [kafka]
via GitHub
[jira] [Comment Edited] (KAFKA-14567) Kafka Streams crashes after ProducerFencedException
Matthias J. Sax (Jira)
[jira] [Commented] (KAFKA-14567) Kafka Streams crashes after ProducerFencedException
Matthias J. Sax (Jira)
[jira] [Created] (KAFKA-16915) Update leader change message
Jira
[PR] MINOR: Improve documentation of default.replication.factor config [kafka]
via GitHub
Re: [PR] MINOR: Remove unnecessary log4j-appender dependency and tweak explicit log4j dependency [kafka]
via GitHub
[jira] [Updated] (KAFKA-16662) UnwritableMetadataException: Metadata has been lost
Igor Soarez (Jira)
[jira] [Updated] (KAFKA-16662) UnwritableMetadataException: Metadata has been lost
Igor Soarez (Jira)
[PR] Kafka 16637 cache offset fetch result [kafka]
via GitHub
Re: [PR] Kafka 16637 cache offset fetch result [kafka]
via GitHub
Re: [PR] KAFKA-8305: Doc Fix default.replication.factor [kafka]
via GitHub
Re: [PR] KAFKA-8305: Doc Fix default.replication.factor [kafka]
via GitHub
Re: [PR] KAFKA-8305: Doc Fix default.replication.factor [kafka]
via GitHub
Re: [PR] KAFKA-8305: Doc Fix default.replication.factor [kafka]
via GitHub
[PR] KAFKA-16879 SystemTime should use singleton mode [kafka]
via GitHub
Re: [PR] KAFKA-16879 SystemTime should use singleton mode [kafka]
via GitHub
[PR] KAFKA-16879 SystemTime should use singleton mode [kafka]
via GitHub
Re: [PR] KAFKA-16879 SystemTime should use singleton mode [kafka]
via GitHub
Re: [PR] KAFKA-16879 SystemTime should use singleton mode [kafka]
via GitHub
Re: [PR] KAFKA-16879 SystemTime should use singleton mode [kafka]
via GitHub
[jira] [Comment Edited] (KAFKA-16758) Extend Consumer#close with option to leave the group or not
Lianet Magrans (Jira)
Re: [PR] KAFKA-7632: Support Compression Level [kafka]
via GitHub
Re: [PR] KAFKA-7632: Support Compression Level [kafka]
via GitHub
Re: [PR] MirrorMaker2 Exactly-once Semantics [kafka]
via GitHub
Re: [PR] MirrorMaker2 Exactly-once Semantics [kafka]
via GitHub
Re: [PR] Change "matchingAclExists" method visibility modifier to protected in AclAuthorizer [kafka]
via GitHub
Re: [PR] Change "matchingAclExists" method visibility modifier to protected in AclAuthorizer [kafka]
via GitHub
[PR] KAFKA-16724: Added support for fractional throughput and monotonic payload in kafka-producer-perf-test.sh [kafka]
via GitHub
[jira] [Updated] (KAFKA-16914) Add Share Group dynamic and broker configs
Andrew Schofield (Jira)
Re: [PR] MINOR: Fix some Python warnings [kafka]
via GitHub
Re: [PR] MINOR: Fix some Python warnings [kafka]
via GitHub
Re: [PR] MINOR: Add valid values for message.timestamp.type [kafka]
via GitHub
Re: [PR] MINOR: Add valid values for message.timestamp.type [kafka]
via GitHub
[jira] [Resolved] (KAFKA-5261) Performance improvement of SimpleAclAuthorizer
Mickael Maison (Jira)
Re: [PR] KAFKA-5261 added cached authorizer [kafka]
via GitHub
Re: [PR] KAFKA-5261 added cached authorizer [kafka]
via GitHub
[PR] KAFKA-16890: Update log-start-offset monotonically when deleting overlapping remote segments [kafka]
via GitHub
Re: [PR] KAFKA-16890: Update log-start-offset monotonically when deleting overlapping remote segments [kafka]
via GitHub
Re: [PR] KAFKA-16890: Update log-start-offset monotonically when deleting overlapping remote segments [kafka]
via GitHub
Re: [PR] KAFKA-16890: Compute valid log-start-offset when deleting overlapping remote segments [kafka]
via GitHub
Re: [PR] KAFKA-16890: Compute valid log-start-offset when deleting overlapping remote segments [kafka]
via GitHub
Re: [PR] KAFKA-16890: Compute valid log-start-offset when deleting overlapping remote segments [kafka]
via GitHub
Re: [PR] KAFKA-16890: Compute valid log-start-offset when deleting overlapping remote segments [kafka]
via GitHub
Re: [PR] KAFKA-16890: Compute valid log-start-offset when deleting overlapping remote segments [kafka]
via GitHub
[jira] [Comment Edited] (KAFKA-16638) Align the naming convention for config and default variables in *Config classes
Omnia Ibrahim (Jira)
Re: [PR] KAFKA-4994: Fix findbug warnings about OffsetStorageWriter [kafka]
via GitHub
Re: [PR] KAFKA-4994: Fix findbug warnings about OffsetStorageWriter [kafka]
via GitHub
Re: [PR] Added unit tests for DefaultDecoder and StringDecoder [kafka]
via GitHub
Re: [PR] Added unit tests for DefaultDecoder and StringDecoder [kafka]
via GitHub
[jira] [Created] (KAFKA-16914) Add Shage Group dynamic and broker configs
Apoorv Mittal (Jira)
[jira] [Assigned] (KAFKA-16743) Add support for share group heartbeat in KafkaApis
Apoorv Mittal (Jira)
[jira] [Assigned] (KAFKA-16724) Add new options for kafka-producer-perf-test.sh
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-16913) Support external schemas in JSONConverter
Priyanka K U (Jira)
Re: [PR] KAFKA-16886: Detect replica demotion in AssignmentsManager [kafka]
via GitHub
Re: [PR] KAFKA-16886: Detect replica demotion in AssignmentsManager [kafka]
via GitHub
Re: [PR] KAFKA-16886: Detect replica demotion in AssignmentsManager [kafka]
via GitHub
Earlier messages