三、Kafaka的基本操作

Posted 2023-03-30

参考技术A 在启动Kafka之前，需要启动zookeeper，否则会报错！相关的启动指令如下：

在此配置中，只有一个 ZooKeeper 和代理 id 实例。 配置步骤如下：（注意，以下过程中的topicName表示创建主题的名称，可以自己定义。）
（1）创建Kafka主题
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topicName
创建主题后，会在 Kafka 代理终端窗口中获取通知，并在 config / server.properties 文件中的“/ tmp / kafka-logs /"中指定创建主题的日志。
（2）启动生产者以发送消息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic topicName
生产者命令行客户端需要两个主要参数：
1.代理列表（broker-list）： 要发送邮件的代理列表。 这种情况下，只有一个代理。
2.监听端口： Config / server.properties 文件包含代理端口 ID，可以查到代理正在侦听端口 9092，因此直接指定它。
生产者在 config / producer.properties 文件中指定默认生产者属性。
（3）启动消费者以接收消息
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topicName --from-beginning
消费者在config / consumer.properties 文件中指定了默认消费者属性。 打开一个新终端并键入以下消息消息语法。
（4）在生产者终端输入数据测试
生产者将等待消息的输入并发布到 Kafka 集群。 默认情况下，每行数据都作为新消息发布。在生产者终端输入数据，这些数据都会在消费者终端显示。