spring - 无法从卡夫卡读取

Question

我是卡夫卡的初学者。我正在使用 docker 映像 Landoop ...我使用了控制台生产者和控制台消费者，并且我可以在主题中读/写
现在我正在尝试对 spring 做同样的事情。我能够创建一个新主题，发送消息，但我无法阅读它们。这些是我的 java 类：
这是配置类：

    @EnableKafka
@Configuration
public class KafkaConsumerConfig {

    @Bean
    public ConsumerFactory<String, String> consumerFactory() {
        Map<String, Object> config = new HashMap<>();

        config.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "127.0.0.1:9092");
        config.put(ConsumerConfig.GROUP_ID_CONFIG, "group_id");
        config.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
        config.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);

        return new DefaultKafkaConsumerFactory<>(config);
    }

    @Bean
    public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContainerFactory() {
        ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory();
        factory.setConsumerFactory(consumerFactory());
        return factory;
    }
}

这是消费者

public class ConsumerService {
    @KafkaListener(topics = "user.subscription", group = "group_id")
    public void consume(String message) {
        System.out.println("Consumed message: " + message);
    }

}

非常感谢您提前

标签： springdockerapache-kafkaspring-kafka