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<String, MessageTo> consumer;