WIP

[demos/kafka/outbox] / src / main / java / de / trion / kafka / outbox / OutboxProducer.java

diff --git a/src/main/java/de/trion/kafka/outbox/OutboxProducer.java b/src/main/java/de/trion/kafka/outbox/OutboxProducer.java
index 99adae9..d493aee 100644 (file)
--- a/src/main/java/de/trion/kafka/outbox/OutboxProducer.java
+++ b/src/main/java/de/trion/kafka/outbox/OutboxProducer.java
@@ -3,7 +3,6 @@ package de.trion.kafka.outbox;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.kafka.clients.producer.ProducerRecord;
-import org.apache.kafka.common.serialization.LongSerializer;
 import org.apache.kafka.common.serialization.StringSerializer;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -35,7 +34,7 @@ public class OutboxProducer {
     }
 
 
-    public void send(Event event) {
+    public void send(UserEvent event) {
         try {
             String json = mapper.writeValueAsString(event);
             ProducerRecord<String, String> record = new ProducerRecord<>(topic, event.user, json);