Kafka简介及基本原理与使用场景(3)

三个机器都配置完成后，可以使用./bin/kafka-server.sh -daemon ./config/servers.properties命令来打开kafka。打开命令后使用jps查看运行状态如下：

eversilver@debian:/usr/local/kafka$ jps 10273 Jps 8994 QuorumPeerMain 10026 Kafka

下面可以使用一个例子查看配置是否正确。创建一个主题。命令如下：

eversilver@debian:/usr/local/kafka$ ./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 1 --topic test Created topic "test".

查看当前的主题

eversilver@debian:/usr/local/kafka$ bin/kafka-topics.sh --list --zookeeper localhost:2181 test #当前的test主题已经存在

启动一个kafka的生产者：

eversilver@debian:/usr/local/kafka$ bin/kafka-console-producer.sh --broker-list 192.168.128.128:19092 --topic test

另一台机器上启动一个kafka的消费者

eversilver@debian:/usr/local/kafka$ bin/kafka-console-consumer.sh --bootstrap-server 192.168.128.129:19092 --topic test --from-beginning

当在生产者端输入"hello"后，消费者端也会正常显示"hello"
同样可以通过命令查看topic的基本信息：

eversilver@debian:/usr/local/kafka$ ./bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test Topic:test PartitionCount:1 ReplicationFactor:1 Configs: Topic: test Partition: 0 Leader: 1 Replicas: 1 Isr: 1

kafka的日志目录下的server.log是kafka集群的机器进行leader切换时产生的日志。state.change.log日志。controller.log存放的是kafka集群中的controller所产生的日志。