Kafka 生产者、消费者命令行操作

1.查看操作生产者命令参数

bin/kafka-console-producer.sh

参数

--bootstrap-server <String: server toconnect to> ，连接的 Kafka Broker 主机名称和端口号。

--topic <String: topic>，操作的 topic 名称。

2.发送消息

bin/kafka-console-producer.sh --bootstrap-server hadoop102:9092 --topic first

3.消费者命令行操作

bin/kafka-console-consumer.sh

参数

--bootstrap-server <String: server toconnect to> ，连接的 Kafka Broker 主机名称和端口号。

--topic <String: topic>，操作的 topic 名称。

4.消费消息，再开一个终端

bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --topic first

好像没有收到hello,再发些消息。

查看消费者

这次收到了新发的两个信息，这是因为hello在启动消费者之前发的信息，所以收不到。可以添加一个参数，收到历史信息。

bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --topic first --from-beginning

这样就能收到历史消息

执行的语句bin/kafka-console-producer.sh --bootstrap-server 10.0.0.11:9092 --topic test

但是报错了原因是版本不支持

It's not until Kafka 2.5.0, console producer accepts --bootstrap-server,
before this version, use --broker-list

在2.5.0版本之前只支持 --broker-list
在2.5.0版本之后支持 --bootstrap-server

kafka连接生产者（消费者其实也一样的问题）出现了下面这个报错：（

WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

找到配置文件在kafka内的config/server.properties

在配置plaintext的时候，地址配置的是master（master是我在/etc/hosts文件里面配置的127.0.0.1），而我连接的时候，使用的是：

 bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

改为：

bin/kafka-console-producer.sh --broker-list master:9092 --topic test

Kafka 生产者、消费者命令行操作相关推荐

kafka 基础概念、命令行操作（查看所有topic、创建topic、删除topic、查看某个Topic的详情、修改分区数、发送消息、消费消息、查看消费者组、更新消费者的偏移位置）
文章目录前言 1. 基础概念 Broker Producer Consumer Consumer Group Topic Partition Replica 2. 命令行操作 2.1 查看所有top ...
【kafka】三、kafka命令行操作
kafka命令行操作 kafka的相关操作命令脚本文件在bin目录下查看所有的topic kafka-topics.sh --zookeeper hll1:2181 --list 或 kafka-t ...
简单的kafka命令行操作
目录一.主题topic命令行操作 1.查看操作主题的命令参数 2.连接kafka地址,创建名为kaf的主题,指定分区和副本数量 3.查看所有主题的名称 4.查看主题的详细信息 5.修改主题(修改分区 ...
数据仓库 — 07_Kafka的安装与部署（Kafka命令行操作指令、Kafka集群群起脚本、压力测试、节点数量计算、hadoop_zookeeper_flume_kafka群起脚本、默认端口总结）
文章目录 1 Kafka的安装与配置 2 Kafka命令行操作 2.1 查看当前服务器中的所有topic 2.2 创建topic 2.3 删除topic 2.4 发送消息 2.5 消费消息 2.6 查 ...
kafka 命令行操作大全
kafka 命令行操作大全一.集群相关常用命令二.topic相关常用命令 2.1 脚本&参数简介 2.2 举例三.生产者命令行常用操作 3.1 脚本&参数简介 3.2 举例发送消 ...
kafka _命令行操作
kafka _命令行操作 #启动zk zkServer.start #启动kafka kafka-server-start.sh -daemon /opt/kafka/config/server.pr ...
大数据6_03_Kafka命令行操作
3 Kafka命令行操作总结: # 和topic有关的命令:都使用 kafka-topics-sh --zookeeper hadoop102:2181 + 操作 # 和生产消息有关的:使用brok ...
DOS命令行操作MySQL常用命令
平时用可视化界面用惯了,如果紧急排查问题,没有安装可视化工具的话,只能通过命令来看了. 以备不时之需,我们要熟悉一下命令行操作MySQL. 打开DOS命令窗口:WIN + R 输入cmd,回车然后输 ...
github命令行操作
首先做准备工作,安装github客户端Git Shell和GitHub,GitHub用于界面化操作,本次主要说一下如果用命令行操作, 1.打开Git Shell,进入本地项目库,cd F:gitdem ...

Kafka 生产者、消费者命令行操作

Kafka 生产者、消费者命令行操作

Kafka 生产者、消费者命令行操作相关推荐

最新文章

热门文章