Skip to content

Commit c4b6460

Browse files
javaHelperjavaHelper
committed
DLQ
1 parent d972b5d commit c4b6460

File tree

7 files changed

+67
-82
lines changed

7 files changed

+67
-82
lines changed

‎16-dead-letter-topic/dlt-consumer/pom.xml‎

Lines changed: 58 additions & 58 deletions
Original file line numberDiff line numberDiff line change
@@ -1,63 +1,63 @@
11
<?xml version="1.0" encoding="UTF-8"?>
22
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
3-
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
4-
<modelVersion>4.0.0</modelVersion>
5-
<parent>
6-
<groupId>org.springframework.boot</groupId>
7-
<artifactId>spring-boot-starter-parent</artifactId>
8-
<version>2.7.5</version>
9-
<relativePath/> <!-- lookup parent from repository -->
10-
</parent>
11-
<groupId>com.course.kafka</groupId>
12-
<artifactId>dlt-consumer</artifactId>
13-
<version>0.0.1-SNAPSHOT</version>
14-
<name>dlt-consumer</name>
15-
<description>Demo project for Spring Boot</description>
16-
<properties>
17-
<java.version>11</java.version>
18-
</properties>
19-
<dependencies>
20-
<dependency>
21-
<groupId>org.springframework.boot</groupId>
22-
<artifactId>spring-boot-starter-web</artifactId>
23-
</dependency>
24-
<dependency>
25-
<groupId>org.springframework.kafka</groupId>
26-
<artifactId>spring-kafka</artifactId>
27-
</dependency>
3+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
4+
<modelVersion>4.0.0</modelVersion>
5+
<parent>
6+
<groupId>org.springframework.boot</groupId>
7+
<artifactId>spring-boot-starter-parent</artifactId>
8+
<version>3.3.1</version>
9+
<relativePath/> <!-- lookup parent from repository -->
10+
</parent>
11+
<groupId>com.course.kafka</groupId>
12+
<artifactId>dlt-consumer</artifactId>
13+
<version>0.0.1-SNAPSHOT</version>
14+
<name>dlt-consumer</name>
15+
<description>Demo project for Spring Boot</description>
2816

29-
<dependency>
30-
<groupId>org.projectlombok</groupId>
31-
<artifactId>lombok</artifactId>
32-
<optional>true</optional>
33-
</dependency>
34-
<dependency>
35-
<groupId>org.springframework.boot</groupId>
36-
<artifactId>spring-boot-starter-test</artifactId>
37-
<scope>test</scope>
38-
</dependency>
39-
<dependency>
40-
<groupId>org.springframework.kafka</groupId>
41-
<artifactId>spring-kafka-test</artifactId>
42-
<scope>test</scope>
43-
</dependency>
44-
</dependencies>
17+
<properties>
18+
<java.version>11</java.version>
19+
</properties>
4520

46-
<build>
47-
<plugins>
48-
<plugin>
49-
<groupId>org.springframework.boot</groupId>
50-
<artifactId>spring-boot-maven-plugin</artifactId>
51-
<configuration>
52-
<excludes>
53-
<exclude>
54-
<groupId>org.projectlombok</groupId>
55-
<artifactId>lombok</artifactId>
56-
</exclude>
57-
</excludes>
58-
</configuration>
59-
</plugin>
60-
</plugins>
61-
</build>
21+
<dependencies>
22+
<dependency>
23+
<groupId>org.springframework.boot</groupId>
24+
<artifactId>spring-boot-starter-web</artifactId>
25+
</dependency>
26+
<dependency>
27+
<groupId>org.springframework.kafka</groupId>
28+
<artifactId>spring-kafka</artifactId>
29+
</dependency>
30+
<dependency>
31+
<groupId>org.projectlombok</groupId>
32+
<artifactId>lombok</artifactId>
33+
<optional>true</optional>
34+
</dependency>
35+
<dependency>
36+
<groupId>org.springframework.boot</groupId>
37+
<artifactId>spring-boot-starter-test</artifactId>
38+
<scope>test</scope>
39+
</dependency>
40+
<dependency>
41+
<groupId>org.springframework.kafka</groupId>
42+
<artifactId>spring-kafka-test</artifactId>
43+
<scope>test</scope>
44+
</dependency>
45+
</dependencies>
6246

63-
</project>
47+
<build>
48+
<plugins>
49+
<plugin>
50+
<groupId>org.springframework.boot</groupId>
51+
<artifactId>spring-boot-maven-plugin</artifactId>
52+
<configuration>
53+
<excludes>
54+
<exclude>
55+
<groupId>org.projectlombok</groupId>
56+
<artifactId>lombok</artifactId>
57+
</exclude>
58+
</excludes>
59+
</configuration>
60+
</plugin>
61+
</plugins>
62+
</build>
63+
</project>

‎16-dead-letter-topic/dlt-consumer/src/main/java/com/course/kafka/config/KafkaConfig.java‎

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -48,10 +48,11 @@ public ConcurrentKafkaListenerContainerFactory<Object, Object> invoiceDltContain
4848
var factory = new ConcurrentKafkaListenerContainerFactory<Object, Object>();
4949
configurer.configure(factory, consumerFactory());
5050

51-
var recoverer = new DeadLetterPublishingRecoverer(kafkaTemplate, (record, ex) -> new TopicPartition("t-invoice-dead", record.partition()));
51+
var recoverer = new DeadLetterPublishingRecoverer(kafkaTemplate,
52+
(record, ex) -> new TopicPartition("t-invoice-dead", record.partition()));
5253

5354
factory.setCommonErrorHandler(new DefaultErrorHandler(recoverer, new FixedBackOff(1000, 5)));
5455

5556
return factory;
5657
}
57-
}
58+
}

‎16-dead-letter-topic/dlt-consumer/src/main/java/com/course/kafka/consumer/InvoiceConsumer.java‎

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -26,8 +26,6 @@ public void consume(String message) throws JsonMappingException, JsonProcessingE
2626
if (invoice.getAmount() < 100000) {
2727
throw new IllegalArgumentException("Invalid amount for " + invoice);
2828
}
29-
3029
LOG.info("Processing invoice : {}", invoice);
3130
}
32-
33-
}
31+
}

‎16-dead-letter-topic/dlt-producer/pom.xml‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
<parent>
66
<groupId>org.springframework.boot</groupId>
77
<artifactId>spring-boot-starter-parent</artifactId>
8-
<version>2.7.5</version>
8+
<version>3.3.1</version>
99
<relativePath/> <!-- lookup parent from repository -->
1010
</parent>
1111
<groupId>com.course.kafka</groupId>
@@ -60,4 +60,4 @@
6060
</plugins>
6161
</build>
6262

63-
</project>
63+
</project>

‎16-dead-letter-topic/dlt-producer/src/main/java/com/course/kafka/producer/InvoiceProducer.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ public class InvoiceProducer {
1919

2020
public void send(Invoice invoice) throws JsonProcessingException {
2121
var json = objectMapper.writeValueAsString(invoice);
22-
kafkaTemplate.send("t-invoice", invoice.getAmount() % 2, invoice.getInvoiceNumber(), json);
22+
kafkaTemplate.send("t-invoice", invoice.getAmount() % 2,
23+
invoice.getInvoiceNumber(), json);
2324
}
24-
2525
}

‎16-dead-letter-topic/dlt-producer/src/main/java/com/course/kafka/service/InvoiceService.java‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,5 +18,4 @@ public Invoice generateInvoice() {
1818

1919
return new Invoice(invoiceNumber, amount, "USD");
2020
}
21-
22-
}
21+
}

‎16-dead-letter-topic/dlt-producer/src/test/java/com/course/kafka/DltProducerApplicationTests.java‎

Lines changed: 0 additions & 13 deletions
This file was deleted.

0 commit comments

Comments
 (0)