kafka学习（2）主题 Topic

Topic主题：

消息在进入kafka集群时，是以主题进行 数据概括，既一条消息必须属于一个主题。

在kafka集群中能够有无数个主题。

从生产者的角度来讲，他所操做的单位，通常状况下是以主题为单位。从消费者的角度来讲，他所操做的单位，也是以主题为单位。

可是，生产者，消费者能够以比主题更精细的单位来操做----》分区，也就是消息的分类。

kafka始终支持多用户写入消息，订阅消息的。生产者和消费者，必需要知道操做的主题。

建立属于本身的主题：

经常使用命令：

启动kafka

Java\kafka_2.11-0.10.0.0>.\bin\windows\kafka-server-start.bat .\config\server.properties

 

windows 下查看主题 
D:\Java\kafka_2.11-0.10.0.0\bin\windows>kafka-topics.bat --describe --zookeeper localhost:2181 --topic     business_log（主题的名字）

 

查看主题的content
D:\Java\kafka_2.11-0.10.0.0\bin\windows>kafka-console-consumer.bat --zookeeper localhost:2181 --from-beginning --topic business_log（主题的名字）

 

往主题写入消息
kafka-console-producer.bat --broker-list localhost:9092 --topic business_log

建立一个主题：

bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic business_log（主题的名字）

在建立主题时，能够设置不少属性参数，须要哪些参数，能够查找参数设置表

查看全部建立的主题列表：

bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
 

完全删除本机kafka的topic

   1.server.properties 中添加delete.topic.enable=true

   2.执行D:\Developer\kafka_2.10-0.10.0.0\bin\windows>kafka-topics.bat --zookeeper 127.0.0.1（本机的IP）:2181 --delete --topic business_log（主题的名字）

  3. 执行zookeeper-server-stop.bat，重启kafka

如果从新发送消息，会自动根据配置的partitions重建。

注意：不执行1步骤，就是假删除

一个broker服务下，是否能够建立多个主题？

能够

一个broker服务下，在建立主题时是否能够建立多个副本因子？

不能够，建立主题时的副本因子，应该小于等于可用的broker服务数。

 

 

查看主题和分区信息：

在kafka中，每一个分区有一个编号，这个编号从0开始，

Leader：表示broker.id=0（server.properties文件中）若是有多个broker，那么broker.id的值确定不相同，由于在kafka中若是有多个副本的话，就会存在leader与follower的关系。表示当前这个复本为leader所在的broker是哪个。

Replicas：全部的复本列表， 0,1,2

Isr：可用列表数，0,1,2

只看主题。