[
https://issues.apache.org/jira/browse/KAFKA-19911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Francis Godinho resolved KAFKA-19911.
-------------------------------------
Resolution: Duplicate
> Flaky test ShareConsumerTest.testShareGroupMaxSizeConfigExceeded
> ----------------------------------------------------------------
>
> Key: KAFKA-19911
> URL: https://issues.apache.org/jira/browse/KAFKA-19911
> Project: Kafka
> Issue Type: Test
> Components: clients
> Reporter: Francis Godinho
> Assignee: Francis Godinho
> Priority: Major
> Labels: flaky-test
> Fix For: 4.2.0
>
>
> [https://develocity.apache.org/scans/tests?search.relativeStartTime=P28D&search.rootProjectNames=kafka&search.timeZoneId=America%2FLos_Angeles&tests.container=org.apache.kafka.clients.consumer.ShareConsumerTest&tests.test=testShareGroupMaxSizeConfigExceeded()%5B1%5D]
>
> {code:java}
> org.opentest4j.AssertionFailedError: Condition not met within timeout 30000.
> The 4th consumer was not kicked out of the group ==> expected: <true> but
> was: <false>at
> org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:151)at
>
> org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:132)at
> org.junit.jupiter.api.AssertTrue.failNotTrue(AssertTrue.java:63)at
> org.junit.jupiter.api.AssertTrue.assertTrue(AssertTrue.java:36)at
> org.junit.jupiter.api.Assertions.assertTrue(Assertions.java:214)at
> org.apache.kafka.test.TestUtils.lambda$waitForCondition$5(TestUtils.java:445)at
>
> org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:493)at
> org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:442)at
> org.apache.kafka.clients.consumer.ShareConsumerTest.testShareGroupMaxSizeConfigExceeded(ShareConsumerTest.java:2370)at
> java.lang.reflect.Method.invoke(Method.java:569)at
> java.util.Optional.ifPresent(Optional.java:178)at
> java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1625)at
>
> java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:762)at
> java.util.ArrayList.forEach(ArrayList.java:1511)at
> java.util.ArrayList.forEach(ArrayList.java:1511) {code}
> Fail logs:
> {code:java}
> [2025-11-19 10:02:14,812] WARN 'share' in
> group.coordinator.rebalance.protocols is deprecated. Share groups are
> controlled by the 'share.version' feature; this broker config will be ignored
> in a future release. (kafka.server.KafkaConfig:73)
> [2025-11-19 10:02:14,829] WARN 'share' in
> group.coordinator.rebalance.protocols is deprecated. Share groups are
> controlled by the 'share.version' feature; this broker config will be ignored
> in a future release. (kafka.server.KafkaConfig:73)
> [2025-11-19 10:02:14,830] WARN 'share' in
> group.coordinator.rebalance.protocols is deprecated. Share groups are
> controlled by the 'share.version' feature; this broker config will be ignored
> in a future release. (kafka.server.KafkaConfig:73)
> [2025-11-19 10:02:14,834] WARN 'share' in
> group.coordinator.rebalance.protocols is deprecated. Share groups are
> controlled by the 'share.version' feature; this broker config will be ignored
> in a future release. (kafka.server.KafkaConfig:73)
> [2025-11-19 10:02:14,844] WARN 'share' in
> group.coordinator.rebalance.protocols is deprecated. Share groups are
> controlled by the 'share.version' feature; this broker config will be ignored
> in a future release. (kafka.server.KafkaConfig:73)
> [2025-11-19 10:02:14,845] WARN 'share' in
> group.coordinator.rebalance.protocols is deprecated. Share groups are
> controlled by the 'share.version' feature; this broker config will be ignored
> in a future release. (kafka.server.KafkaConfig:73)
> Bootstrap metadata:
> BootstrapMetadata(records=[ApiMessageAndVersion(FeatureLevelRecord(name='metadata.version',
> featureLevel=29) at version 0),
> ApiMessageAndVersion(FeatureLevelRecord(name='eligible.leader.replicas.version',
> featureLevel=1) at version 0),
> ApiMessageAndVersion(FeatureLevelRecord(name='group.version', featureLevel=1)
> at version 0), ApiMessageAndVersion(FeatureLevelRecord(name='share.version',
> featureLevel=1) at version 0),
> ApiMessageAndVersion(FeatureLevelRecord(name='streams.version',
> featureLevel=1) at version 0),
> ApiMessageAndVersion(FeatureLevelRecord(name='transaction.version',
> featureLevel=2) at version 0)], metadataVersionLevel=29, source=format
> command)
> Formatting metadata directory /tmp/kafka-14829393993145388027/controller_3000
> with metadata.version 4.2-IV1.
> Bootstrap metadata:
> BootstrapMetadata(records=[ApiMessageAndVersion(FeatureLevelRecord(name='metadata.version',
> featureLevel=29) at version 0),
> ApiMessageAndVersion(FeatureLevelRecord(name='eligible.leader.replicas.version',
> featureLevel=1) at version 0),
> ApiMessageAndVersion(FeatureLevelRecord(name='group.version', featureLevel=1)
> at version 0), ApiMessageAndVersion(FeatureLevelRecord(name='share.version',
> featureLevel=1) at version 0),
> ApiMessageAndVersion(FeatureLevelRecord(name='streams.version',
> featureLevel=1) at version 0),
> ApiMessageAndVersion(FeatureLevelRecord(name='transaction.version',
> featureLevel=2) at version 0)], metadataVersionLevel=29, source=format
> command)
> Formatting metadata directory /tmp/kafka-14829393993145388027/broker_0_data0
> with metadata.version 4.2-IV1.
> [2025-11-19 10:02:14,870] WARN 'share' in
> group.coordinator.rebalance.protocols is deprecated. Share groups are
> controlled by the 'share.version' feature; this broker config will be ignored
> in a future release. (kafka.server.KafkaConfig:73)
> [2025-11-19 10:02:14,871] WARN 'share' in
> group.coordinator.rebalance.protocols is deprecated. Share groups are
> controlled by the 'share.version' feature; this broker config will be ignored
> in a future release. (kafka.server.KafkaConfig:73)
> [2025-11-19 10:02:14,875] WARN 'share' in
> group.coordinator.rebalance.protocols is deprecated. Share groups are
> controlled by the 'share.version' feature; this broker config will be ignored
> in a future release. (kafka.server.KafkaConfig:73)
> [2025-11-19 10:02:14,887] WARN 'share' in
> group.coordinator.rebalance.protocols is deprecated. Share groups are
> controlled by the 'share.version' feature; this broker config will be ignored
> in a future release. (kafka.server.KafkaConfig:73)
> [2025-11-19 10:02:14,924] WARN [QuorumController id=3000] Performing
> controller activation. The metadata log appears to be empty. Appending 6
> bootstrap record(s) in metadata transaction at metadata.version 4.2-IV1 from
> bootstrap source 'testkit'. (org.apache.kafka.controller.QuorumController:106)
> [2025-11-19 10:02:14,951] WARN 'share' in
> group.coordinator.rebalance.protocols is deprecated. Share groups are
> controlled by the 'share.version' feature; this broker config will be ignored
> in a future release. (kafka.server.KafkaConfig:73)
> [2025-11-19 10:02:15,010] WARN 'share' in
> group.coordinator.rebalance.protocols is deprecated. Share groups are
> controlled by the 'share.version' feature; this broker config will be ignored
> in a future release. (kafka.server.KafkaConfig:73)
> [2025-11-19 10:02:15,024] WARN 'share' in
> group.coordinator.rebalance.protocols is deprecated. Share groups are
> controlled by the 'share.version' feature; this broker config will be ignored
> in a future release. (kafka.server.KafkaConfig:73)
> [2025-11-19 10:02:15,256] WARN Share groups and KafkaShareConsumer are part
> of a preview feature introduced by KIP-932, and are not recommended for use
> in production.
> (org.apache.kafka.clients.consumer.internals.ShareConsumerDelegateCreator:48)
> [2025-11-19 10:02:20,615] WARN Share groups and KafkaShareConsumer are part
> of a preview feature introduced by KIP-932, and are not recommended for use
> in production.
> (org.apache.kafka.clients.consumer.internals.ShareConsumerDelegateCreator:48)
> [2025-11-19 10:02:20,616] WARN Share groups and KafkaShareConsumer are part
> of a preview feature introduced by KIP-932, and are not recommended for use
> in production.
> (org.apache.kafka.clients.consumer.internals.ShareConsumerDelegateCreator:48)
> [2025-11-19 10:02:20,617] WARN Share groups and KafkaShareConsumer are part
> of a preview feature introduced by KIP-932, and are not recommended for use
> in production.
> (org.apache.kafka.clients.consumer.internals.ShareConsumerDelegateCreator:48)
> [2025-11-19 10:02:35,623] WARN Share groups and KafkaShareConsumer are part
> of a preview feature introduced by KIP-932, and are not recommended for use
> in production.
> (org.apache.kafka.clients.consumer.internals.ShareConsumerDelegateCreator:48)
> [2025-11-19 10:02:35,632] ERROR [ShareConsumer clientId=consumer-group1-241,
> groupId=group1] ShareGroupHeartbeatRequest failed due to
> GROUP_MAX_SIZE_REACHED: The share group has reached its maximum capacity of 3
> members.
> (org.apache.kafka.clients.consumer.internals.ShareHeartbeatRequestManager:405)
> [2025-11-19 10:02:35,632] ERROR [ShareConsumer clientId=consumer-group1-241,
> groupId=group1] Member parZioqNSU-v1HQJcS9PTg with epoch 0 transitioned to
> fatal state
> (org.apache.kafka.clients.consumer.internals.ShareMembershipManager:445)
> [2025-11-19 10:02:40,628] WARN [ShareConsumer clientId=consumer-group1-241,
> groupId=group1] Exception thrown in acknowledgement commit callback
> (org.apache.kafka.clients.consumer.internals.ShareConsumerImpl:618)
> org.apache.kafka.common.errors.GroupMaxSizeReachedException: The share group
> has reached its maximum capacity of 3 members.
> [2025-11-19 10:03:06,758] ERROR No share partition found for groupId group1
> topicPartition aB3To2-gSTyuhHYJPFV0Ng:topic-0 while releasing acquired topic
> partitions (kafka.server.share.SharePartitionManager:380)
> [2025-11-19 10:03:06,760] ERROR No share partition found for groupId group1
> topicPartition aB3To2-gSTyuhHYJPFV0Ng:topic-0 while releasing acquired topic
> partitions (kafka.server.share.SharePartitionManager:380)
> [2025-11-19 10:03:06,855] WARN [ShareConsumer clientId=consumer-group1-239,
> groupId=group1] Connection to node 0 (localhost/127.0.0.1:44511) could not be
> established. Node may not be available.
> (org.apache.kafka.clients.NetworkClient:899)
> [2025-11-19 10:03:06,859] WARN [ShareConsumer clientId=consumer-group1-238,
> groupId=group1] Connection to node 0 (localhost/127.0.0.1:44511) could not be
> established. Node may not be available.
> (org.apache.kafka.clients.NetworkClient:899)
> [2025-11-19 10:03:06,864] WARN [ShareConsumer clientId=consumer-group1-240,
> groupId=group1] Connection to node 0 (localhost/127.0.0.1:44511) could not be
> established. Node may not be available.
> (org.apache.kafka.clients.NetworkClient:899)
> [2025-11-19 10:03:06,868] WARN [ShareConsumer clientId=consumer-group1-241,
> groupId=group1] Connection to node 0 (localhost/127.0.0.1:44511) could not be
> established. Node may not be available.
> (org.apache.kafka.clients.NetworkClient:899)
> [2025-11-19 10:03:06,870] WARN [ShareConsumer clientId=consumer-group1-241,
> groupId=group1] Connection to node -1 (localhost/127.0.0.1:44511) could not
> be established. Node may not be available.
> (org.apache.kafka.clients.NetworkClient:899)
> [2025-11-19 10:03:06,870] WARN [ShareConsumer clientId=consumer-group1-241,
> groupId=group1] Bootstrap broker localhost:44511 (id: -1 rack: null isFenced:
> false) disconnected (org.apache.kafka.clients.NetworkClient:1255)
> [2025-11-19 10:03:06,961] WARN [ShareConsumer clientId=consumer-group1-238,
> groupId=group1] Connection to node 0 (localhost/127.0.0.1:44511) could not be
> established. Node may not be available.
> (org.apache.kafka.clients.NetworkClient:899)
> [2025-11-19 10:03:06,968] WARN [ShareConsumer clientId=consumer-group1-240,
> groupId=group1] Connection to node 0 (localhost/127.0.0.1:44511) could not be
> established. Node may not be available.
> (org.apache.kafka.clients.NetworkClient:899)
> [2025-11-19 10:03:06,977] WARN [NodeToControllerChannelManager id=3000
> name=registration] Attempting to close NetworkClient that has already been
> closed. (org.apache.kafka.clients.NetworkClient:744) {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
