Java Kafka基本操作

安装zookeeper

下载镜像：docker pull zookeeper:3.4.14

创建容器：docker run -d --name zookeeper -p 2181:2181 zookeeper:3.4.14

安装kafka

下载容器：docker pull wurstmeister/kafka:2.12-2.3.1

创建容器：

docker run -d --name kafka
--env KAFKAADVERTISED HOST NAME-192.168200.130
--env KAFKA Z0OKEEPER CONNECT-192.168.200130:2181
--env KAFKAADVERTISED LISTENERS-PLAINTEXT://192.168.200.130:9092
--env KAFKA LISTENERS=PLAINTEXT://0.0.0.0:9092--envKAFKAHEAPOPTS="-Xmx256M-Xms256M”
-p 9092:9092 wurstmeister/kafka:2.12-2.3.1

入门案例

导入依赖

 
     org.springframework.kafka
     spring-kafka
     
         
             org.apache.kafka
             kafka-clients
         
     
 
 
     org.apache.kafka
     kafka-clients