From 6f031ecd6c7b06212aae0c38b279c497a0f67464 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 12 Nov 2022 23:10:09 +0100
Subject: [PATCH] Vorlage
---
pom.xml | 4 ----
src/main/java/de/juplo/kafka/SimpleConsumer.java | 6 ------
2 files changed, 10 deletions(-)
diff --git a/pom.xml b/pom.xml
index b908802c..6528ee9b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -61,10 +61,6 @@
<build>
<plugins>
- <plugin>
- <groupId>pl.project13.maven</groupId>
- <artifactId>git-commit-id-plugin</artifactId>
- </plugin>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
diff --git a/src/main/java/de/juplo/kafka/SimpleConsumer.java b/src/main/java/de/juplo/kafka/SimpleConsumer.java
index fe0479f1..e9ce220e 100644
--- a/src/main/java/de/juplo/kafka/SimpleConsumer.java
+++ b/src/main/java/de/juplo/kafka/SimpleConsumer.java
@@ -17,17 +17,11 @@ public class SimpleConsumer
private String id;
private long consumed = 0;
- @KafkaListener(topics = "${simple.consumer.topic}")
private void handleRecord(
- @Header(KafkaHeaders.RECEIVED_TOPIC)
String topic,
- @Header(KafkaHeaders.RECEIVED_PARTITION_ID)
Integer partition,
- @Header(KafkaHeaders.OFFSET)
Long offset,
- @Header(KafkaHeaders.RECEIVED_MESSAGE_KEY)
String key,
- @Payload
String value)
{
consumed++;
--
2.20.1