Потребитель Spring-Kafka не получает сообщения автоматически

Question

У меня есть потребитель kafka с пружинной загрузкой и производитель kafka с весенней загрузкой, когда я запускаю потребителя в терминале и после запуска производителя, потребитель получает данные тогда и только тогда, когда я нажимаю любую клавишу клавиатуры и не нажимаю не знаю почему? Вот моя конфигурация.

public ConsumerFactory<String, DataSet> dataSetConsumerFactory() { /* string group id */
        /* set up le consumer factory */
        String clientId = "pattern-" + groupid;
        Map<String, Object> props = new HashMap<>();
        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapAddress); /* kafka server */
        props.put(ConsumerConfig.GROUP_ID_CONFIG, groupid);/* group id */
        props.put(ConsumerConfig.CLIENT_ID_CONFIG, clientId); /* client id */
        props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "latest"); /* reset offset */
        return new DefaultKafkaConsumerFactory<>(props, new StringDeserializer(),
                new JsonDeserializer<>(DataSet.class));
    }

Answer 1

Проблема в windows, когда вы выбираете что-то в терминале, рабочий процесс останавливается, поэтому вам нужно нажать любую клавишу клавиатуры, чтобы запустить его снова.