[type:feat]add kafka logging e2e test

apache · Jan 19, 2025 · 88c0c20 · 88c0c20
1 parent 642cdf3
commit 88c0c20
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...g-kafka/src/test/java/org/apache/shenyu/e2e/testcase/logging/kafka/DividePluginCases.java b/...g-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);