Kafka学习入门(windows环境下)

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属性是集群中每个节点的名称,这一名称是唯一且永久的。我们必须重写端口和日志目录,因为我们在同一台机器上运行这些,我们不希望所有的代理尝试在同一个端口注册,或者覆盖彼此的数据。

 

相关文章