中文字幕精品亚洲无线码二区,国产黄a三级三级三级看三级,亚洲七七久久桃花影院,丰满少妇被猛烈进入,国产小视频在线观看网站

springboot~連接kafka需要注意的地方

kafka需要zookeeper的支持,我們可以使用docker-compose簡單的部署一個環境,在部署時,kafka需要我們為它配置一個hostname,這個名稱是每個kafka節點(broken)的名稱,也是很容易被忽視的地方,通過kafka客戶端工具可以看到你當前部署kafka時的hostsname,在部署java時,你的主機也需要配置這個host.

部署一個kafka

docker-compose實現

version: '2'
services:
  zookeeper:
    image: wurstmeister/zookeeper
    hostname: zookeeper1
    network_mode: bridge
    ports:
      - "2181:2181"
  kafka:
    image: wurstmeister/kafka:2.11-0.11.0.3
    hostname: kafka1
    network_mode: bridge
    links:
      - zookeeper
    ports:
      - "9092:9092" #表示宿主機的端口為隨機,這樣方便使用docker-compose scale 進行擴容
    environment:
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://:9092
      KAFKA_LISTENERS: PLAINTEXT://:9092
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181

部署一個應用,使用k8s配置容器hosts

spec:
  template:
    spec:
      hostAliases:
        - ip: "192.168.60.146"
          hostnames: ["kafka1"]

在java應用中可以直接連接kafka的地址和端口

posted @ 2021-09-03 09:53  張占嶺  閱讀(950)  評論(0)    收藏  舉報