Kafka并不难学 (3) 基本操作

Zookeeper的作用及背景

• 管理代码中的变量的配置
• 设置命名服务
• 提升系统的可用性和安全性
• 管理Kafka集群

Zookeeper单机模式和分布式模式

单机模式

• zkServer.sh start
• zkServer.sh status
• zkServer.sh stop

分布式模式

Kafka单机模式和分布式模式

如何操作主题？

创建：

kafka-topics.sh --create --zookeeper dn1:2181 --replication-factor 1 --partitions 1 --topic test

查看：

kafka-topics.sh --describe --zookeeper dn1:2181 --topic test

修改：

kafka-topics.sh --alter --zookeeper dn1:2181 test --config max.message.bytes=102400

删除：

kafka-topics.sh --delete --zookeeper dn1:2181 test