公司內網kafka需要外部訪問,通過外網埠對映到kakfa內網某個埠
docker下部署的kafka,使用映象為:confluentinc/cp-kafka
公司外網和內網對映:ip1:10001—>ip2:10002
kakfa內網ip為ip2
kafka核心配置如下:(ip1,ip2對應各自內外網ip)
kafka:
image: confluentinc/cp-kafka
ports:
- 10002:10002 #外網訪問埠
- 9093:9093 #內網訪問埠
environment:
# listeners
kafka_listeners: internal://:9093,external://:10002
# advertised_listeners
kafka_advertised_listeners: internal://:9093,external://:10001
kafka_inter_broker_listener_name: internal
kafka_listener_security_protocol_map: internal:sasl_plaintext,external:sasl_plaintext
listeners就是主要用來定義kafka broker的listener的配置項。
advertised.listeners引數的作用就是將broker的listener資訊發布到zookeeper中,供clients(producer/consumer)使用。如果配置了advertised.listeners,那麼就不會將listeners配置的資訊發布到zookeeper中去了
可以參考此文章kafka從上手到實踐-kafka集群:kafka listeners,其實具體還是不理解。
docker容器下安裝kafka例項
docker 環境的安裝可以參考 docker簡介和linux下安裝 進入正題 docker pull wurstmeister zookeeper啟動執行zookeeper映象的例項 docker run d name zookeeper 01 p 2181 2181 t wurstmeister...
docker下搭建kafka服務相關命令
docker start zookeeper sudo docker run d name kafka publish 9092 9092 link zookeeper env kafka zookeeper connect zookeeper 2181 env kafka advertised h...
Kafka試用記錄
為了初步了解kafka功能和效能,通過實驗簡單試用。1 kafka 2.9.1 0.8.2.1演示 zookeeper server 192.168.1.66 2181 kafka server 192.168.1.66 9092 kafka consumer 192.168.1.55 wget t...