Kafka学习笔记（三、Kafka CLI与Kafka Java API）

目录：

• Kafka CLI
• Kafka Java API

Kafka CLI

1、kafka-topic.sh：可创建、删除、修改、查看topic，并且还可以查看topic列表。

• 查看topic列表：./kafka-topics.sh --list --zookeeper 127.0.0.1:2181
• 查看topic详情：./kafka-topics.sh --describe --zookeeper 127.0.0.1:2181 --topic topicName
• 创建一个topic：./kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --topic topicName --partitions 3 --replication-factor 3（1个主题，3个分区，3个副本；副本因子不能超过broker数量）
• 删除一个topic：./kafka-topics.sh --delete --zookeeper 127.0.0.1:2181 --topic topicName
• 修改一个topic：./kafka-topics.sh --alter --zookeeper zkHost:zkPort --topic topic-01 --partitions 3

2、kafka-console-producer.sh：生产者

• 生产一条消息：./kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic topicName

3、kafka-console-consumer.sh：消费者

• 消费一条消息：./kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic topicName

Kafka Java API

Java中通过org.apache.kafka.clients.admin.AdminClient操作topics

• 创建topic：public CreateTopicsResult createTopics(Collection<NewTopic> newTopics)
• 删除topic：public DeleteTopicsResult deleteTopics(Collection<String> topics)
• 列表topic：public ListTopicsResult listTopics()
• 查询topic：public DescribeTopicsResult describeTopics(Collection<String> topicNames)
• 等等

生产消息：org.apache.kafka.clients.producer.KafkaProducer、org.apache.kafka.clients.producer.ProducerRecord。

消费消息：