启动zookeeper
docker run -d --name zookeeper -p 2181:2181 -v /etc/localtime:/etc/localtime wurstmeister/zookeeper

//启动kafka
docker run  -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=192.168.31.52:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.31.52:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -t wurstmeister/kafka

application.properties

spring.kafka.bootstrap-servers=192.168.31.52:9092
spring.kafka.consumer.group-id=test-consumer-group
spring.kafka.consumer.enable-auto-commit=true
spring.kafka.consumer.auto-commit-interval=3000

生产者:

@RestController
public class MyTest {

    @Autowired
    private KafkaTemplate kafkaTemplate;

    @GetMapping(value = "/test" )
    public void findPage(){
        kafkaTemplate.send("test", "你好");
    }

}

消费者:

@Component
class KafkaConsumer {

    @KafkaListener(topics = {"test"})
    public void handleMessage(String record) {
        System.out.println("res==>"+record);
    }


}

pom:

        <dependency>
            <groupId>org.springframework.kafka</groupId>
            <artifactId>spring-kafka</artifactId>
        </dependency>