Java Kafka基本操作

开发运维 2023-10-05 竹子爱熊猫 手机阅读

  • 安装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