1.创建一个topic (它有一个分区和副本)
bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
2.查看已有的topic
bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
3.发送消息
bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test //test表示把消息发送到名为test的topic中
Kafka自带一个命令行客户端,它从文件或标准输入中获取输入,并将其作为message(消息)发送到Kafka集群。默认情况下,每行将作为单独的message发送。
4.启动一个 consumer 接收消息
bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
5.设置多代理集群
(1)为每一个代理创建配置文件(复制config
/server
.properties文件,修改配置中的端口号
)
复制出了配置文件:server-1.properties 与 server-2.properties
修改主要配置项:
config/server-1.properties: broker.id=1 listeners=PLAINTEXT://:9093 log.dir=/tmp/kafka-logs-1
注:broker.id
属性是集群中每个节点的名称,这一名称是唯一且永久的。我们必须重写端口和日志目录,因为我们在同一台机器上运行这些,我们不希望所有的代理尝试在同一个端口注册,或者覆盖彼此的数据。