topic 创建、申请、指标查看等操作;
topic 管控、治理、集群运维操作。
简而言之,开源版的LogiKM在平台UI展示和商业版相同,但是部分功能无法使用,因为商业版依赖滴滴自建的KafkaGateway,目前该组件没有开源。
Kafka 用户:关注的是 Topic 相关的操作,Topic 资源申请与扩容、Topic 指标监控、Topic 消费告警、Topic 消息采样、Topic 消费重置等。
Kafka 运维:关注的是 Kafka 集群相关的操作,集群监控、集群安装、集群升级、集群 Topic 迁移、集群容量规划等。
本地搭建zk
10.10.10.10
docker run -d --name zookeeper -p 2181:2181 -t -v /etc/localtime:/etc/localtime wurstmeister/zookeeper
本地搭建kafka集群
docker run -d --name kafka1 --publish 9092:9092 --publish 9988:9988 --link zookeeper -v /etc/localtime:/etc/localtime --env KAFKA_BROKER_ID=1 \
--env KAFKA_ZOOKEEPER_CONNECT=10.10.10.10:2181 \
--env KAFKA_ADVERTISED_HOST_NAME=10.10.10.10 \
--env KAFKA_ADVERTISED_PORT=9092 \
--env JMX_PORT=9988 \
wurstmeister/kafka:latest
docker run -d --name kafka2 --publish 9093:9093 --publish 9989:9989 --link zookeeper -v /etc/localtime:/etc/localtime --env KAFKA_BROKER_ID=2 \
--env KAFKA_ZOOKEEPER_CONNECT=10.10.10.10:2181 \
--env KAFKA_ADVERTISED_HOST_NAME=10.10.10.10 \
--env KAFKA_ADVERTISED_PORT=9093 \
--env JMX_PORT=9989 \
wurstmeister/kafka:latest
docker run -d --name kafka3 --publish 9094:9094 --publish 9990:9990 --link zookeeper -v /etc/localtime:/etc/localtime --env KAFKA_BROKER_ID=3 \
--env KAFKA_ZOOKEEPER_CONNECT=10.10.10.10:2181 \
--env KAFKA_ADVERTISED_HOST_NAME=10.10.10.10 \
--env KAFKA_ADVERTISED_PORT=9094 \
--env JMX_PORT=9990 \
wurstmeister/kafka:latest
创建个终端进行测试
docker run --rm -it wurstmeister/kafka:latest bash
kafka-console-producer.sh --broker-list 10.10.10.10:9092,10.10.10.10:9093,10.10.10.10:9094 --topic zzd-test1
kafka-console-consumer --bootstrap-server 10.10.10.10:9092,10.10.10.10:9093,10.10.10.10:9094 --from-beginning --topic zzd-test1