1.首先在pom.xml中引入spring-kafka jar：<dependency><groupId>org.springframework.kafka</groupId><artifactId>spring-kafka</artifactId></dependency>2.创建kafkaListenerF...

一、前言spring-kafka通过 @KafkaListener 的方式配置订阅的topic，通过@Configuration 配置创建kafkaListenerContainerFactory。如下：@Configuration@EnableKafkapublic class KafkaConfig {private static final String KAFKA_S...

一，问题描述：搭建本地kafka环境，默认端口为9092server.properties中默认配置为：# advertised.listeners=PLAINTEXT://10.13.84.109:9092消费者Demo程序如下：while (true) {if(consumer != null){// timeo...

一，问题描述在修改添加hash类型时，可能会出现一下报错：MISCONF Redis is configured to save RDB snapshots, but is currently not able to persist on disk. Commands that may modify the data set are disabled. Please check Redis log