个人资料：

spring.kafka.consumer.bootstrap-servers=127.0.0.1:9092  
spring.kafka.consumer.group-id=home  
spring.kafka.consumer.enable-auto-commit=false  
spring.kafka.consumer.max-poll-records=10  
spring.kafka.consumer.auto-commit-interval=100  
spring.kafka.consumer.fetch-max-wait=10000  
spring.kafka.listener.ack-mode=manual_immediate  

消费者：

@KafkaListener(topicPartitions={@TopicPartition(topic = "aaa",partitions = {"0"})},group = "home")  
public void doConsume(ConsumerRecord a){  
    log.info("000000 received kafka message:{},offset={}",a.value(),a.offset());  
}

@KafkaListener(topicPartitions={@TopicPartition(topic = "aaa",group = "home")  
public void doConsume1(ConsumerRecord a){  
    log.info("111111 received  kafka message:{},a.offset());  
}

制作人：

@Scheduled(cron = "0/2 * * * * ?")  
public void doProduce(){  
  for(int i =0;i<5;i++){  
     kafkaTemplate.send("aaa","say my name!"+ UUID.randomUUID());  
  }  
}

登录控制台：

111111 收到 kafka 消息：说出我的名字！3d0e7171-cae1-44c9-8a9a-f21289160108,offset=42141
000000 收到 kafka 消息：说出我的名字！3d0e7171-cae1-44c9-8a9a-f21289160108,offset=42141
111111 收到 kafka 消息：说出我的名字！90851ac4-1e5f-4ac8-93c9-72acd64ce529,offset=42142
000000 收到 kafka 消息：说出我的名字！90851ac4-1e5f-4ac8-93c9-72acd64ce529,offset=42142
111111 收到 kafka 消息：说出我的名字！4d0fa93d-c7e7-4f44-beba-bfa6c25aee12,offset=42143
111111 收到 kafka 消息：说出我的名字！d1707959-0be2-4ec1-a81d-86ef211cb73d,offset=42144
000000 收到 kafka 消息：说出我的名字！4d0fa93d-c7e7-4f44-beba-bfa6c25aee12,offset=42143
111111 收到 kafka 消息：说出我的名字！79cfea0d-548d-437d-bd05-8b65a27f9e9a,offset=42145
000000 收到 kafka 消息：说出我的名字！d1707959-0be2-4ec1-a81d-86ef211cb73d,offset=42144
000000 收到 kafka 消息：说出我的名字！79cfea0d-548d-437d-bd05-8b65a27f9e9a,offset=42145

实际上，两个消费者根据控制台中的消息消费相同的消息。 谢谢。