配置config文件为:server.properties
脚本在 kafka/bin路径下
启动kafka:

./kafka-server-start.sh ../config/server.properties 1>/dev/null 2>&1 &     # kafka-server-start.sh

查看已创建的topic列表:

./kafka-topics.sh --list --zookeeper localhost:2181

查看对应topic的描述信息:

./kafka-topics.sh --describe --zookeeper xx.x.xxx.xxx:2181 --topic xxxxx.xx.xxxxx.xxx     # --zookeeper为zookeeperIP, --topic为topic名称

消费消息:

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic xxxxx.xx.xxxxx.xxx --from-beginning    # 若没有任何返回或没有响应,则该topic中没有数据内容;否则有

kafka消费之kafka查看topic是否有数据相关推荐

  1. kafka查看topic中的数据_实战!Kafka Manager能统计出Topic中的记录条数吗?

    问题描述 今天现场实施同事说Kafka Manager上显示有3500w条记录,但使用我们的平台落地后,一统计发现只有2200w条记录,这是不是说明我们的平台存在丢数据的可能. 经了解,对接方是通过如 ...

  2. 查看当前服务器中的所有的topic,创建topic,删除topic,通过shell命令发送消息,通过shell消费消息,查看topic详情,对分区数进行修改

    一. Kafka常用操作命令  查看当前服务器中的所有topic [root@hadoop3 kafka]# bin/kafka-topics.sh --list --zookeeper hadoo ...

  3. Kafka系列(六)、Kafka开发套件kafka lenses 安装及使用(带WebUI)

    目录 介绍 安装 使用 Kafka系列: kafka 2.4.1单机版部署及使用 kafka监控系统kafka eagle安装使用 滴滴开源的kafka-manager编译及部署使用 kafka管理监 ...

  4. Kafka创建查看topic,生产消费指定topic消息

    启动zookeeper和Kafka之后,进入kafka目录(安装/启动kafka参考前面一章:https://www.cnblogs.com/cici20166/p/9425613.html) 1.创 ...

  5. Kafka 命令之查看topic生产消费数据查看组的消费信息

    1.创建 topic: [root@node1 bin]# ./kafka-topics.sh --zookeeper node2:2181,node3:2181,node3:2181 --creat ...

  6. Java程序创建Kafka Topic,以及数据生产消费,常用的命令

    转自: Java程序创建Kafka Topic,以及数据生产消费,常用的命令_Zyy_z_的博客-CSDN博客_java kafka创建topicKafka简介: Kafka是一个分布式发布--订阅消 ...

  7. kafka专题:kafka的Topic主题、Partition分区、消费组偏移量offset等基本概念详解

    文章目录 1. kafka集群整体架构 2. kafka相关元素的基本概念 2.1 主题Topic和分区Partition 2.2 kafka消息存储在哪里? 2.3 分区副本 2.4 消费组和偏移量 ...

  8. kafka消费组查看和删除

    生产环境监控发现kafka存在大量消费组 查看消费组信息: ./kafka-consumer-groups.sh --bootstrap-server ip:port --list 查看特定消费组信息 ...

  9. Flink系列之:基于scala语言实现flink实时消费Kafka Topic中的数据

    Flink系列之:基于scala语言实现flink实时消费Kafka Topic中的数据 一.引入flink相关依赖 二.properties保存连接kafka的配置 三.构建flink实时消费环境 ...

最新文章

  1. Spring Boot 注解大全,一键收藏!回城路上复习!
  2. LeetCode 1049. 最后一块石头的重量 II
  3. c语言江宝钏实验六答案,C语言程序设计江宝钏著实验六答案
  4. 颈椎病分型及对症治疗
  5. springboot2.0新特性
  6. 您的设备不支持googleplay服务_google play下载-google play下载安卓
  7. 二分查找的平均查找长度_二分查找(折半查找)代码实现
  8. java面试突击第一季 github,Github上星标77.6K+Java面试突击版笔记在咸鱼被疯传,太香了...
  9. 3~7串锂电池保护板
  10. “数据科学”课程群与 “数据科学导论”课程建设初探
  11. 教你做系统的公众号选题规划,建立自己的选题库
  12. 计算机右键管理删除,【win7右键菜单管理】右键菜单的设置及清除
  13. Designing Network Design Spaces,译读
  14. 二战字节跳动成功上岸,准备了小半年,拿27k也算不上很高吧~
  15. 查看BMP格式图片的十六进制代码
  16. 关于特征值特征向量和矩阵分解的理解总结
  17. 错题本Android Studio
  18. 2020茶艺师(中级)模拟考试及茶艺师(中级)模拟考试题库
  19. Vue 实现骨架屏(skeleton)
  20. 泛微协同OA制造业解决方案

热门文章

  1. java实现扑克牌移动
  2. Java线程面试题(超高频 超详细!!)
  3. IE9卸载后无法安装的解决办法
  4. idea热部署-解决热部署失效问题-【伸手党福利】
  5. linux普通用户监听1024以下的端口(80、443)
  6. 【100%通过率】华为机试真题 C++ 实现【对称美学】【2022.11 Q4 新题】
  7. 网易雷火游戏测试实习一二三四面面经
  8. 如何在WP7上用XNA写2D游戏(一)
  9. 磊科路由器后门利用情况分析
  10. Vue-组件通信6种方式