This is an automated email from the ASF dual-hosted git repository.
AndrewJSchofield pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 124a8179b7a KAFKA-20686: Reduce share heartbeat timeout in DLQ integ
tests. [3/N] (#22702)
124a8179b7a is described below
commit 124a8179b7aa2cfd0ce347dca239d9abdb7cc8f8
Author: Sushant Mahajan <[email protected]>
AuthorDate: Tue Jun 30 01:14:58 2026 +0530
KAFKA-20686: Reduce share heartbeat timeout in DLQ integ tests. [3/N]
(#22702)
Currently we are using default 5 sec timeout for share consumer
heartbeats which in a timed scenario like a test could cause flakiness.
This PR aims to improve the overall hygiene by setting it to more
reasonable 1.5 sec.
Reviewers: Shivsundar R <[email protected]>, Andrew Schofield
<[email protected]>
---
.../java/org/apache/kafka/clients/consumer/ShareConsumerDLQTest.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ShareConsumerDLQTest.java
b/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ShareConsumerDLQTest.java
index 9abb85fc1b9..b3f7eb09afb 100644
---
a/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ShareConsumerDLQTest.java
+++
b/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ShareConsumerDLQTest.java
@@ -63,7 +63,9 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
@ClusterConfigProperty(key = "offsets.topic.replication.factor", value
= "1"),
@ClusterConfigProperty(key = "share.coordinator.state.topic.min.isr",
value = "1"),
@ClusterConfigProperty(key =
"share.coordinator.state.topic.num.partitions", value = "3"),
- @ClusterConfigProperty(key =
"share.coordinator.state.topic.replication.factor", value = "1")
+ @ClusterConfigProperty(key =
"share.coordinator.state.topic.replication.factor", value = "1"),
+ @ClusterConfigProperty(key = "group.share.min.heartbeat.interval.ms",
value = "1500"),
+ @ClusterConfigProperty(key = "group.share.heartbeat.interval.ms",
value = "1500")
}
)
public class ShareConsumerDLQTest extends ShareConsumerTestBase {
