From f0d629a1d8597e0a0091a0a9474d9654e211b2d8 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Fri, 14 Apr 2023 10:17:21 +0200 Subject: [PATCH] WIP --- .../chat/backend/persistence/kafka/ChatHomeConsumer.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatHomeConsumer.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatHomeConsumer.java index b6f5e426..21a6e1a7 100644 --- a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatHomeConsumer.java +++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/ChatHomeConsumer.java @@ -2,13 +2,12 @@ package de.juplo.kafka.chat.backend.persistence.kafka; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; - -import java.util.function.Consumer; +import org.apache.kafka.clients.consumer.Consumer; @RequiredArgsConstructor @Slf4j -public class ChatHomeConsumer extends Run +public class ChatHomeConsumer extends Runnable { private final Consumer consumer; -- 2.20.1