Kafka Consumer не всегда получает сообщения

Question

Итак, у меня есть этот Kafka Consumer, но он не всегда получает сообщения от моего производителя, и я не уверен, имеет ли это отношение к серверам Zookeeper / Kafka, случайно умирающим или как-то связанному с кодом.

Интересно, это распространенная проблема?

Производитель:

    public SentenceProducer() {
        Properties properties = new Properties();
        properties.put("bootstrap.servers", "localhost:9092");
        properties.put("client.id", SentenceProducer.class.getName());
        producer = new KafkaProducer(properties, new StringSerializer(), new StringSerializer());
    }

Потребитель:

    public SentenceConsumer() {
        Properties properties = new Properties();
        properties.put("bootstrap.servers", "localhost:9092");
        properties.put("client.id", SentenceConsumer.class.getName());
        properties.put("group.id", "test");
        consumer = new KafkaConsumer(properties, new StringDeserializer(), new StringDeserializer());
        consumer.subscribe(Collections.singletonList("sentence"));
        detector = new LanguageDetector();
    }