Kafka创建查看topic，生产消费指定topic消息

启动zookeeper和Kafka之后，进入kafka目录（安装/启动kafka参考前面一章：https://www.cnblogs.com/cici20166/p/9425613.html）

1.创建Topic

　　1）运行命令： ./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1

　　2181 是zookeeper 端口

　　图示为创建成功：

2.查看Topic

　　1）运行命令查看所有的topic： ./bin/kafka-topics.sh --list --zookeeper localhost:2181

　　结果如下图，表示共有test和test1两个topic：

3.用Kafka的console-producer在topic test1 生产消息

　　新建终端窗口，到/Applications/kafka目录，运行命令：./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test1

　　然后输入想要产生的消息内容（如 hello world），回车：

4.用Kafka的console-consumer 消费topic test1的消息

　　新建终端窗口，到/Applications/kafka目录，

　　运行命令：./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test1 --from-beginning

　　（9092是kafka单机启动的端口；--bootstrap-server 新旧kafka版本不一样，这个是新版本的命令）

　　ps. 1)若producer 和 consumer 两个窗口同时打开，在producer输入信息，consumer会立即消费信息并打印在终端

　　　 2）新开一个终端，去消费同一个topic，刚刚已经消费过的消息还会被新终端继续消费。也就是说，消息被消费过后不会立即被删除。　　　　　　　　　　　

Kafka创建查看topic，生产消费指定topic消息相关推荐

kafka带kerberos和sasl安全认证：命令行消费指定topic数据
1.什么是kerberos? Kerberos(/ˈkərbərəs/)是一种计算机网络授权协议,用来在非安全网络中,对个人通信以安全的手段进行身份认证.这个词又指麻省理工学院为这个协议开发的一套计算 ...
kafka创建topic_ELK-基础系列(六)-ELK加入消息队列-Kafka部署
Kafka集群部署指南一.前言 1.Kafka简介 Kafka是一个开源的分布式消息引擎/消息中间件,同时Kafka也是一个流处理平台.Kakfa支持以发布/订阅的方式在应用间传递消息,同时并基于消 ...
Kafka 命令之查看topic生产消费数据查看组的消费信息
1.创建 topic: [root@node1 bin]# ./kafka-topics.sh --zookeeper node2:2181,node3:2181,node3:2181 --creat ...
MAC搭建kafka客户端以及实现生产消费
Kafka 部分参数说明 (1)max.in.flight.requests.per.connection Kafka 可以保证同一个分区里的消息是有序的.也就是说,如果生产者按照一定的顺序发送消息, ...
kafka 的pom文件_Flink 消费 Kafka 数据
kafka核心概念: Kafka 是一个消息队列,生产者向消息队列中写入数据,消费者从队列中获取数据并进行消费.可以认为一个 Topic 就是一个队列,每个 Topic 又会被分成多个 Partiti ...
Java程序创建Kafka Topic，以及数据生产消费，常用的命令
转自: Java程序创建Kafka Topic,以及数据生产消费,常用的命令_Zyy_z_的博客-CSDN博客_java kafka创建topicKafka简介: Kafka是一个分布式发布--订阅消 ...
查看当前服务器中的所有的topic，创建topic,删除topic,通过shell命令发送消息，通过shell消费消息，查看topic详情,对分区数进行修改
一. Kafka常用操作命令  查看当前服务器中的所有topic [root@hadoop3 kafka]# bin/kafka-topics.sh --list --zookeeper hadoo ...
kafka tool 查看指定group下topic的堆积数量_ELK架构下利用Kafka Group实现Logstash的高可用...
系统运维的过程中,每一个细节都值得我们关注下图为我们的基本日志处理架构所有日志由Rsyslog或者Filebeat收集,然后传输给Kafka,Logstash作为Consumer消费Kafka里边 ...
kafka 创建topic，查看topic
创建创建kafka topic bin/kafka-topics.sh --create --topic topicname --replication-factor 1 --partitions ...

Kafka创建查看topic，生产消费指定topic消息

Kafka创建查看topic，生产消费指定topic消息相关推荐

最新文章

热门文章