配置大全

Broker配置
Topic配置
生产者配置
消费者配置
Stream配置
Connect配置
AdminClient配置

接口大全

生产者接口

日常维护操作

机器扩容

改变分区数

./kafka-topics.sh –zookeeper zookeepIP:2181 -alter –partitions 5 –topic topicName

指定生产路由

 自定义一个类实现 org.apache.kafka.clients.producer.Partitioner 接口
 同时在创建 KafkaProducer 实例时配置 partitioner.class 参数

创建主题

/usr/local/kafka/bin/kafka-topics.sh --create --zookeeper zookeeperip:2181 --replication-factor 2 --partitions 15 --topic TEST1.user

控制台消费者

/usr/local/kafka/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic *.user --from-beginning

控制台生产者

/usr/local/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic *.user