import de.juplo.kafka.chat.backend.domain.Message;
import org.apache.kafka.clients.consumer.Consumer;
import org.apache.kafka.common.TopicPartition;
import de.juplo.kafka.chat.backend.domain.Message;
import org.apache.kafka.clients.consumer.Consumer;
import org.apache.kafka.common.TopicPartition;