Kafka学习入门(windows环境下)
2020-12-27 12:28
标签:replica nbsp text 数据 这一 创建 标准输入 listener plain 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)为每一个代理创建配置文件(复制 复制出了配置文件:server-1.properties 与 server-2.properties 修改主要配置项: Kafka学习入门(windows环境下) 标签:replica nbsp text 数据 这一 创建 标准输入 listener plain 原文地址:https://www.cnblogs.com/yxcn/p/13344810.htmlconfig
/server
.properties文件,修改配置中的端口号
)config/server-1.properties:
broker.id=1
listeners=PLAINTEXT://:9093
log.dir=/tmp/kafka-logs-1
注:broker.id
属性是集群中每个节点的名称,这一名称是唯一且永久的。我们必须重写端口和日志目录,因为我们在同一台机器上运行这些,我们不希望所有的代理尝试在同一个端口注册,或者覆盖彼此的数据。