Francis Godinho created KAFKA-19911:
---------------------------------------
Summary: 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
Fix For: 4.2.0
[https://develocity.apache.org/scans/tests?search.relativeStartTime=P90D&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)
