From 88c0c20784ec17aa982a91728981588c100bda01 Mon Sep 17 00:00:00 2001
From: huk <2509913103@qq.com>
Date: Sun, 19 Jan 2025 20:31:35 +0800
Subject: [PATCH] [type:feat]add kafka logging e2e test

---
 .../shenyu/e2e/testcase/logging/kafka/DividePluginCases.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/shenyu-e2e/shenyu-e2e-case/shenyu-e2e-case-logging-kafka/src/test/java/org/apache/shenyu/e2e/testcase/logging/kafka/DividePluginCases.java b/shenyu-e2e/shenyu-e2e-case/shenyu-e2e-case-logging-kafka/src/test/java/org/apache/shenyu/e2e/testcase/logging/kafka/DividePluginCases.java
index fa3ea18d7046..11a1cbc3dd5a 100644
--- a/shenyu-e2e/shenyu-e2e-case/shenyu-e2e-case-logging-kafka/src/test/java/org/apache/shenyu/e2e/testcase/logging/kafka/DividePluginCases.java
+++ b/shenyu-e2e/shenyu-e2e-case/shenyu-e2e-case-logging-kafka/src/test/java/org/apache/shenyu/e2e/testcase/logging/kafka/DividePluginCases.java
@@ -106,6 +106,7 @@ private ShenYuScenarioSpec testKafkaHello() {
                                                 StringDeserializer.class.getName());
                                         props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,
                                                 StringDeserializer.class.getName());
+                                        props.put(ConsumerConfig.GROUP_ID_CONFIG, "my-consumer-group");
                                         props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "shenyu-kafka:9092");
                                         KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
                                         consumer.subscribe(Arrays.asList(TOPIC));
@@ -127,7 +128,7 @@ private ShenYuScenarioSpec testKafkaHello() {
                                             });
                                         }
                                         Assertions.assertTrue(isLog.get());
-                                    } catch (Exception e) {
+                                    } catch (InterruptedException e) {
                                         LOG.info("isLog.get():{}", isLog.get());
                                         LOG.error("error", e);
                                         throw new RuntimeException(e);