Skip to content

Commit 2e34ef2

Browse files
panos-kakospanos-kakos
committed
Merge remote-tracking branch 'origin/JAVA-49665' into JAVA-49665
2 parents 723128e + f5df00b commit 2e34ef2

File tree

293 files changed

+7673
-582
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

293 files changed

+7673
-582
lines changed

‎apache-kafka-4/README.md‎

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
## Apache Kafka
2+
3+
This module contains articles about Apache Kafka.
4+
5+
##### Building the project
6+
You can build the project from the command line using: *mvn clean install*, or in an IDE.

‎apache-kafka-4/pom.xml‎

Lines changed: 84 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,84 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<project xmlns="http://maven.apache.org/POM/4.0.0"
3+
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
5+
<modelVersion>4.0.0</modelVersion>
6+
<artifactId>apache-kafka-4</artifactId>
7+
<name>apache-kafka-4</name>
8+
9+
<parent>
10+
<groupId>com.baeldung</groupId>
11+
<artifactId>parent-modules</artifactId>
12+
<version>1.0.0-SNAPSHOT</version>
13+
</parent>
14+
15+
<dependencies>
16+
<dependency>
17+
<groupId>org.apache.kafka</groupId>
18+
<artifactId>kafka-clients</artifactId>
19+
<version>${kafka.version}</version>
20+
</dependency>
21+
<dependency>
22+
<groupId>org.apache.kafka</groupId>
23+
<artifactId>kafka-streams</artifactId>
24+
<version>${kafka.version}</version>
25+
</dependency>
26+
<dependency>
27+
<groupId>org.slf4j</groupId>
28+
<artifactId>slf4j-api</artifactId>
29+
<version>${org.slf4j.version}</version>
30+
</dependency>
31+
<dependency>
32+
<groupId>com.fasterxml.jackson.core</groupId>
33+
<artifactId>jackson-databind</artifactId>
34+
<version>${jackson.databind.version}</version>
35+
</dependency>
36+
<dependency>
37+
<groupId>org.testcontainers</groupId>
38+
<artifactId>kafka</artifactId>
39+
<version>${testcontainers-kafka.version}</version>
40+
<scope>test</scope>
41+
</dependency>
42+
<dependency>
43+
<groupId>org.testcontainers</groupId>
44+
<artifactId>junit-jupiter</artifactId>
45+
<version>${testcontainers-jupiter.version}</version>
46+
<scope>test</scope>
47+
</dependency>
48+
<dependency>
49+
<groupId>org.awaitility</groupId>
50+
<artifactId>awaitility</artifactId>
51+
<version>${awaitility.version}</version>
52+
<scope>test</scope>
53+
</dependency>
54+
<dependency>
55+
<groupId>org.awaitility</groupId>
56+
<artifactId>awaitility-proxy</artifactId>
57+
<version>${awaitility.version}</version>
58+
<scope>test</scope>
59+
</dependency>
60+
</dependencies>
61+
62+
<build>
63+
<plugins>
64+
<plugin>
65+
<groupId>org.apache.maven.plugins</groupId>
66+
<artifactId>maven-surefire-plugin</artifactId>
67+
<configuration>
68+
<systemPropertyVariables>
69+
<logback.configurationFile>src/test/resources/logback.xml</logback.configurationFile>
70+
</systemPropertyVariables>
71+
</configuration>
72+
</plugin>
73+
</plugins>
74+
</build>
75+
76+
<properties>
77+
<kafka.version>3.9.0</kafka.version>
78+
<testcontainers-kafka.version>1.19.3</testcontainers-kafka.version>
79+
<testcontainers-jupiter.version>1.19.3</testcontainers-jupiter.version>
80+
<jackson.databind.version>2.15.2</jackson.databind.version>
81+
<awaitility.version>3.0.0</awaitility.version>
82+
</properties>
83+
84+
</project>

apache-kafka-2/src/main/java/com/baeldung/kafkastreams/CustomProcessingExceptionHandler.java renamed to apache-kafka-4/src/main/java/com/baeldung/kafkastreams/CustomProcessingExceptionHandler.java

File renamed without changes.

apache-kafka-2/src/main/java/com/baeldung/kafkastreams/CustomProductionExceptionHandler.java renamed to apache-kafka-4/src/main/java/com/baeldung/kafkastreams/CustomProductionExceptionHandler.java

File renamed without changes.

apache-kafka-2/src/main/java/com/baeldung/kafkastreams/StreamExceptionHandler.java renamed to apache-kafka-4/src/main/java/com/baeldung/kafkastreams/StreamExceptionHandler.java

File renamed without changes.

apache-kafka-2/src/main/java/com/baeldung/kafkastreams/User.java renamed to apache-kafka-4/src/main/java/com/baeldung/kafkastreams/User.java

File renamed without changes.

apache-kafka-2/src/main/java/com/baeldung/kafkastreams/UserDeserializer.java renamed to apache-kafka-4/src/main/java/com/baeldung/kafkastreams/UserDeserializer.java

File renamed without changes.

apache-kafka-2/src/main/java/com/baeldung/kafkastreams/UserSerde.java renamed to apache-kafka-4/src/main/java/com/baeldung/kafkastreams/UserSerde.java

File renamed without changes.

apache-kafka-2/src/main/java/com/baeldung/kafkastreams/UserSerializer.java renamed to apache-kafka-4/src/main/java/com/baeldung/kafkastreams/UserSerializer.java

File renamed without changes.

apache-kafka-2/src/main/java/com/baeldung/kafkastreams/UserStreamService.java renamed to apache-kafka-4/src/main/java/com/baeldung/kafkastreams/UserStreamService.java

File renamed without changes.

0 commit comments

Comments
 (0)