(iggy) branch master updated: test(server): add QUIC transport coverage to consumer group scenarios (#3207)

[hgruszecki]

This is an automated email from the ASF dual-hosted git repository.

hubcio pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iggy.git


The following commit(s) were added to refs/heads/master by this push:
     new 93227c17d test(server): add QUIC transport coverage to consumer group 
scenarios (#3207)
93227c17d is described below

commit 93227c17d4ebe830752b323e6a5f8a85d6b7d004
Author: Anurag <58452562+expl...@users.noreply.github.com>
AuthorDate: Mon May 4 14:27:50 2026 +0530

    test(server): add QUIC transport coverage to consumer group scenarios 
(#3207)
---
 core/integration/tests/server/cg.rs | 13 ++++++-------
 1 file changed, 6 insertions(+), 7 deletions(-)

diff --git a/core/integration/tests/server/cg.rs 
b/core/integration/tests/server/cg.rs
index 8095e1260..c366129bf 100644
--- a/core/integration/tests/server/cg.rs
+++ b/core/integration/tests/server/cg.rs
@@ -24,10 +24,9 @@ use crate::server::scenarios::{
 use integration::iggy_harness;
 
 // Consumer group scenarios do not support HTTP (stateful operations).
-// TODO: Add QUIC support.
 
 #[iggy_harness(
-    test_client_transport = [Tcp, WebSocket],
+    test_client_transport = [Tcp, WebSocket, Quic],
     server(tcp.socket.override_defaults = true, tcp.socket.nodelay = true)
 )]
 async fn join(harness: &TestHarness) {
@@ -35,7 +34,7 @@ async fn join(harness: &TestHarness) {
 }
 
 #[iggy_harness(
-    test_client_transport = [Tcp, WebSocket],
+    test_client_transport = [Tcp, WebSocket, Quic],
     server(tcp.socket.override_defaults = true, tcp.socket.nodelay = true)
 )]
 async fn single_client(harness: &TestHarness) {
@@ -43,7 +42,7 @@ async fn single_client(harness: &TestHarness) {
 }
 
 #[iggy_harness(
-    test_client_transport = [Tcp, WebSocket],
+    test_client_transport = [Tcp, WebSocket, Quic],
     server(tcp.socket.override_defaults = true, tcp.socket.nodelay = true)
 )]
 async fn multiple_clients(harness: &TestHarness) {
@@ -51,7 +50,7 @@ async fn multiple_clients(harness: &TestHarness) {
 }
 
 #[iggy_harness(
-    test_client_transport = [Tcp, WebSocket],
+    test_client_transport = [Tcp, WebSocket, Quic],
     server(tcp.socket.override_defaults = true, tcp.socket.nodelay = true)
 )]
 async fn auto_commit_reconnection(harness: &TestHarness) {
@@ -59,7 +58,7 @@ async fn auto_commit_reconnection(harness: &TestHarness) {
 }
 
 #[iggy_harness(
-    test_client_transport = [Tcp, WebSocket],
+    test_client_transport = [Tcp, WebSocket, Quic],
     server(tcp.socket.override_defaults = true, tcp.socket.nodelay = true)
 )]
 async fn new_messages_after_restart(harness: &TestHarness) {
@@ -67,7 +66,7 @@ async fn new_messages_after_restart(harness: &TestHarness) {
 }
 
 #[iggy_harness(
-    test_client_transport = [Tcp, WebSocket],
+    test_client_transport = [Tcp, WebSocket, Quic],
     server(tcp.socket.override_defaults = true, tcp.socket.nodelay = true)
 )]
 async fn offset_cleanup(harness: &TestHarness) {