三、Kafaka的基本 *** 作

在启动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 集群。 默认情况下，每行数据都作为新消息发布。在生产者终端输入数据，这些数据都会在消费者终端显示。

公司app有banner 展示，后台同学有反应banner 埋点数据上报次数异常多，多达亿级别，差点把kafaka 多给干爆了