kafka 环境的安装

docker run -d --name zookeeper_zh --restart always --network kafka-net -e ALLOW_ANONYMOUS_LOGIN=yes -p 2181:2181 bitnami/zookeeper

docker run -d --restart=always --name kafka_zh \

-p 9092:9092 \

-e KAFKA_BROKER_ID=0 \

-e KAFKA_ZOOKEEPER_CONNECT=192.168.50.146:2181 \

-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.50.146:9092 \

-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 \

-e ALLOW_PLAINTEXT_LISTENER=yes \

bitnami/kafka

# 安装管理软件

docker run -d \

    -p 8089:8080 \

    -e DEFAULT_USERNAME=admin \

    -e DEFAULT_PASSWORD=admin \

    --name kafka-map \

    --restart always dushixiang/kafka-map

kafka 的数据中心

现在的 kafka 是使用 zookeeper 保存 broker、主题、还有分区的消息的。例如 kafka 的消费者会默认每隔一分钟，就会将偏移量往 zookeeper 记录一次。以供消费者群组内的某个消费者失效时重新读取。

巴特西

Kafka -- 基本操作

kafka 环境的安装

kafka 的数据中心

最新文章

热门文章