Create v3

bakdata · Apr 3, 2024 · efedaac · efedaac
1 parent 812114a
commit efedaac
Show file tree

Hide file tree

Showing 5 changed files with 21 additions and 5 deletions.
diff --git a/gradle.properties b/gradle.properties
@@ -8,4 +8,5 @@ fluentKafkaVersion=2.12.1-SNAPSHOT
 junitVersion=5.10.2
 mockitoVersion=5.11.0
 assertJVersion=3.25.3
+log4jVersion=2.23.0
 org.gradle.jvmargs=-Xmx2048m
diff --git a/streams-bootstrap-picocli/build.gradle.kts b/streams-bootstrap-picocli/build.gradle.kts
@@ -7,7 +7,7 @@ plugins {
 dependencies {
     api(project(":streams-bootstrap"))
     api(group = "info.picocli", name = "picocli", version = "4.7.5")
-    val log4jVersion = "2.23.0"
+    val log4jVersion: String by project
     implementation(group = "org.apache.logging.log4j", name = "log4j-core", version = log4jVersion)
     implementation(group = "org.apache.logging.log4j", name = "log4j-slf4j2-impl", version = log4jVersion)
 

diff --git a/...ams-bootstrap-picocli/src/test/java/com/bakdata/kafka/integration/StreamsCleanUpTest.java b/...ams-bootstrap-picocli/src/test/java/com/bakdata/kafka/integration/StreamsCleanUpTest.java
@@ -114,10 +114,7 @@ void shouldClean() throws InterruptedException {
                     .as("Output topic is deleted")
                     .isFalse();
 
-            final List<KeyValue<String, Long>> entriesTwice = expectedValues.stream()
-                    .flatMap(entry -> Stream.of(entry, entry))
-                    .collect(Collectors.toList());
-            this.runAndAssertContent(entriesTwice, "All entries are twice in the input topic after the 2nd run", app);
+            this.runAndAssertContent(expectedValues, "All entries are once in the input topic after the 2nd run", app);
         }
     }
 

diff --git a/streams-bootstrap-picocli/src/test/resources/log4j2.xml b/streams-bootstrap-picocli/src/test/resources/log4j2.xml
@@ -0,0 +1,16 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<Configuration>
+    <Appenders>
+        <Console name="Console" target="SYSTEM_OUT">
+            <PatternLayout pattern="%d{HH:mm:ss.SSS} [%t] %-5level %logger{36} - %msg%n"/>
+        </Console>
+    </Appenders>
+    <Loggers>
+        <Logger additivity="false" level="debug" name="com.bakdata">
+            <AppenderRef ref="Console"/>
+        </Logger>
+        <Root level="info">
+            <AppenderRef ref="Console"/>
+        </Root>
+    </Loggers>
+</Configuration>
diff --git a/streams-bootstrap/build.gradle.kts b/streams-bootstrap/build.gradle.kts
@@ -43,6 +43,8 @@ dependencies {
     testImplementation(group = "net.mguenther.kafka", name = "kafka-junit", version = kafkaJunitVersion) {
         exclude(group = "org.slf4j", module = "slf4j-log4j12")
     }
+    val log4jVersion: String by project
+    testImplementation(group = "org.apache.logging.log4j", name = "log4j-slf4j2-impl", version = log4jVersion)
 }
 
 tasks.withType<Test> {