Kafka常用操作

启动kafka：

./kafka-server-start.sh ../config/server.properties &

创建主题：

./kafka-topics.sh --zookeeper localhost:2181 --create --topic test1 --partitions 1 --replication-factor 1 --config max.message.bytes=64000 --config flush.messages=1

查看所有主题：

./kafka-topics.sh --list --zookeeper 192.168.24.11:2181

删除主题：

./kafka-topics.sh --zookeeper 192.168.24.244:2181 --delete --topic 0085000

消费主题：

# 从开始处消费主题
./kafka-console-consumer.sh --zookeeper localhost:2181 --from-beginning --topic 0085000

# 从最新位置消费主题
./kafka-console-consumer.sh --zookeeper localhost:2181 --topic 0085000

改变主题L000000的默认分区数：

/kafka-topics.sh  --zookeeper 192.168.24.238:2181,192.168.24.11:2181,192.168.24.71:2181 --alter --topic L000000 --partitions 2