X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Ftrion%2Fkafka%2Foutbox%2FOutboxProducer.java;h=d493aeeee211a08d7a6b6e3331f5caa712ad97db;hb=0ee5ee46964d25025f73b34836ccd496d171ca39;hp=99adae9a43e3565ab8aca893b2fb85ed4424b6dd;hpb=a498c7ae070b064dc7ea9a453b389ecff5c190ce;p=demos%2Fkafka%2Foutbox

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
--- 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);