标签：compose zookeeper 192.168 KAFKA CLIENT docker kafka config

文章目录

• 一、docker-compose.yml
• 二、kafkamanager/kafka-manager连接zookeeper
• 三、PHP生产者、消费者连接
• 总结

一、docker-compose.yml

version: '3'
services:
  zookeeper:
    image: bitnami/zookeeper
    container_name: zoo
    restart: always
    ports:
      - 8181:2181
    environment:
      # ZOO_MY_ID: 0
      ALLOW_ANONYMOUS_LOGIN: 'yes'
    networks:
      - app-tier

  kafka:
    image: bitnami/kafka
    container_name: kafka
    ports:
      - 8092:9092
      - 8093:8093
      - 29092:29092
    networks:
      - app-tier
    depends_on:
      - zookeeper
    links:
      - zookeeper
    environment:
      KAFKA_BROKER_ID: 1
      KAFKA_CFG_ZOOKEEPER_CONNECT: zookeeper:2181
      ALLOW_PLAINTEXT_LISTENER: 'yes'
      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: CLIENT:PLAINTEXT,EXTERNAL:PLAINTEXT
      KAFKA_CFG_LISTENERS: CLIENT://:9092,EXTERNAL://:29092
      KAFKA_ADVERTISED_LISTENERS: CLIENT://kafka:9092,EXTERNAL://192.168.85.128:29092
      KAFKA_INTER_BROKER_LISTENER_NAME: CLIENT
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
      KAFKA_ADVERTISED_HOST_NAME: 192.168.85.128
  manager:
    image: kafkamanager/kafka-manager
    container_name: kafka-manager
    depends_on:
      - zookeeper
      - kafka
    environment:
      ZK_HOSTS: zookeeper:2181 
    ports:
      - 9000:9000
    links:
      - zookeeper
      - kafka
    networks:
      - app-tier
networks:
  app-tier:
    driver: bridge

192.168.85.128是虚拟机ip地址
注意容器启动顺序

二、kafkamanager/kafka-manager连接zookeeper

三、PHP生产者、消费者连接

    public function produce()
    {
        $config = ProducerConfig::getInstance();
        $config->setMetadataRefreshIntervalMs(1000);
        $config->setMetadataBrokerList('192.168.85.128:8093');
        $config->setBrokerVersion('1.0.0');
        $config->setRequiredAck(1);
        $config->setIsAsyn(false);
        $config->setProduceInterval(5);
        $producer = new Producer(
            function() {
                return [
                    [
                        'topic' => 'test',
                        'value' => 'test....message.',
                        'key' => 'testkey',
                    ],
                ];
            }
        );
        $producer->success(function($result) {
            var_dump($result);
        });
        $producer->error(function($errorCode) {
                var_dump($errorCode);
        });
        $producer->send(true);
    }

    public function consumer()
    {
        $config = \Kafka\ConsumerConfig::getInstance();
        $config->setMetadataRefreshIntervalMs(10);
        $config->setMetadataBrokerList('192.168.85.128:8093');
        $config->setGroupId('test');
        $config->setBrokerVersion('1.0.0');
        $config->setTopics(array('test'));
        $consumer = new \Kafka\Consumer();
        $consumer->start(function($topic, $part, $message) {
            var_dump($message);
        });
    }

总结

	  KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: CLIENT:PLAINTEXT,EXTERNAL:PLAINTEXT
      KAFKA_CFG_LISTENERS: CLIENT://:9092,EXTERNAL://:29092
      KAFKA_ADVERTISED_LISTENERS: CLIENT://kafka:9092,EXTERNAL://192.168.85.128:29092
      KAFKA_INTER_BROKER_LISTENER_NAME: CLIENT
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
      KAFKA_ADVERTISED_HOST_NAME: 192.168.85.128

2.kafkamanager/kafka-manager连接zookeeper时直接使用docker容器内的连接方式zookeeper:2181

ZK_HOSTS: zookeeper:2181 

标签：compose,zookeeper,192.168,KAFKA,CLIENT,docker,kafka,config
来源： https://blog.csdn.net/u013012063/article/details/120326757

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。