因此，我有一个Kafka消费者，但它并不总是从我的生产者接收消息，我不知道这是否与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();
    }