文档章节

kafka相关脚本操作

各种打杂
 各种打杂
发布于 2017/08/22 17:30
字数 467
阅读 132
收藏 0

1、创建Topic
./kafka-topics.sh --zookeeper cloud17:2181,cloud18:2181,cloud19:2181 --topic PM_TOPIC_KPI2DB_02 --replication-factor 1 --partitions 3 --create

2、Topic列表
./kafka-topics.sh --zookeeper kafka1.sdy:2181,kafka2.sdy:2181,kafka3.sdy:2181 --list

3、创建生产者
./kafka-console-producer.sh --broker-list kafka1.sdy:2181,kafka2.sdy:2181,kafka3.sdy:2181 --topic test_wu_2017

4、消费者
./kafka-console-consumer.sh --zookeeper kafka1.sdy:2181,kafka2.sdy:2181,kafka3.sdy:2181 --topic PM_TOPIC_07 
--from-beginning 每次都是从开始位置消费,在生产环境下不建议这样使用。

5、查看指定topic
./kafka-topics.sh --describe --zookeeper c13-138:2181 --topic mytopic

6、删除topic
./kafka-topics.sh --delete --zookeeper cloud17:2181,cloud18:2181,cloud19:2181 --topic PM_TOPIC

7、显示出Consumer的Group、Topic、分区ID、分区对应已经消费的Offset、logSize大小,Lag以及Owner等信息。
使用脚本:kafka-consumer-offset-checker.sh
./kafka-consumer-offset-checker.sh --zookeeper c13-138:2181,c13-139:2181,c13-141:2181 --topic mytopic --group xb_id --broker-info

8、有时候我们需要验证日志索引是否正确,或者仅仅想从log文件中直接打印消息。
使用脚本:kafka-run-class.sh
./kafka-run-class.sh kafka.tools.DumpLogSegments 
./kafka-run-class.sh kafka.tools.DumpLogSegments  /nodedata/kafka/kafka-logs/xb_topic-0/00000000000000000033.log
./kafka-run-class.sh kafka.tools.DumpLogSegments --files  /nodedata/kafka/kafka-logs/xb_topic-0/00000000000000000033.log --print-data-log

9、导出Zookeeper中Group相关的偏移量。有时候我们需要导出某个Consumer group各个分区的偏移量。
使用脚本:kafka-run-class.sh
./kafka-run-class.sh kafka.tools.ExportZkOffsets
./kafka-run-class.sh kafka.tools.ExportZkOffsets --group xb_id --zkconnect c13-138:2181,c13-139:2181,c13-141:2181 --output-file ~/offset
vim ~/offset

10、这个工具主要作用是从一个Kafka集群里面读取指定Topic的消息,并将这些消息发送到其他集群的指定topic中
使用脚本:./kafka-replay-log-producer.sh 

11、kafka-simple-consumer-shell.sh工具主要是使用Simple Consumer API从指定Topic的分区读取数据并打印在终端
使用脚本:./kafka-simple-consumer-shell.sh --broker-list c13-141:9092 --topic mytopic --partition 0

12、kafka.tools.UpdateOffsetsInZK工具可以更新Zookeeper中指定Topic所有分区的偏移量,可以指定成 earliest或者latest:
使用工具:./kafka-run-class.sh kafka.tools.UpdateOffsetsInZK

最后再说哈kafka的启动和停止。
启动kafka:  ./kafka-server-start.sh /kafka/config/server.properties >/dev/null 2>&1 &
停止kafka: 直接kill掉进程就行。
 

© 著作权归作者所有

上一篇: Proxmox VE
下一篇: logstash笔记
各种打杂

各种打杂

粉丝 2
博文 5
码字总数 8673
作品 0
成都
运维
私信 提问
centos7.6设置开机启动

由于这几天在学习kafka的相关内容,在oracle 虚拟机设置了3台centos7.6版本的服务器需要开机启动kafka和kafka-manager。 首先创建一个启动脚本 daemon.sh 然后将 /etc/rc.d/rc.local 加入启动...

Jian~
08/28
23
0
Oracle Kafka 测试环境搭建

搭建一个 Oracle + Oracle Golden Gate + Kafka Connector 测试环境 ,把类似的oracle的增删改操作发布到Kafka上。所有工具都是有现成的。 类似于这个: https://www.pythian.com/blog/golde...

zb1481207860565
2017/02/03
14
0
Kafka~Linux环境下的部署

概念 Kafka是一种高吞吐量的分布式发布订阅消息系统,它可以处理消费者规模的网站中的所有动作流数据。 这种动作(网页浏览,搜索和其他用户的行动)是在现代网络上的许多社会功能的一个关键...

mcy247
2017/12/06
0
0
Hyperledger Fabric(v1.2.0)代码分析1——channel创建

Hyperledger Fabric(v1.2.0)代码分析1——channel创建 0. e2ecli Hyperledger Fabric提供了一个e2e的例子,该例中创建了一个基础的区块链网络,并进行了交易并查询。麻雀虽小,五脏俱全,我们...

gexin1023
2018/07/25
0
0
kafka在windows上的安装、运行

kafka在windows上的安装、运行 目录(?)[+] 1.简介 Kafka是一种高吞吐量的分布式发布订阅消息系统。详细介绍可查阅官网:kafka官网 2.环境搭建 2.1 安装JDK 下载地址:jre下载 有关jdk的安装不...

yucaifu1989
2018/04/21
0
0

没有更多内容

加载失败,请刷新页面

加载更多

Spring使用ThreadPoolTaskExecutor自定义线程池及实现异步调用

多线程一直是工作或面试过程中的高频知识点,今天给大家分享一下使用 ThreadPoolTaskExecutor 来自定义线程池和实现异步调用多线程。 一、ThreadPoolTaskExecutor 本文采用 Executors 的工厂...

CREATE_17
今天
5
0
CSS盒子模型

CSS盒子模型 组成: content --> padding --> border --> margin 像现实生活中的快递: 物品 --> 填充物 --> 包装盒 --> 盒子与盒子之间的间距 content :width、height组成的 内容区域 padd......

studywin
今天
7
0
修复Win10下开始菜单、设置等系统软件无法打开的问题

因为各种各样的原因导致系统文件丢失、损坏、被修改,而造成win10的开始菜单、设置等系统软件无法打开的情况,可以尝试如下方法解决 此方法只在部分情况下有效,但值得一试 用Windows键+R打开...

locbytes
昨天
8
0
jquery 添加和删除节点

本文转载于:专业的前端网站➺jquery 添加和删除节点 // 增加一个三和一节点function addPanel() { // var newPanel = $('.my-panel').clone(true) var newPanel = $(".triple-panel-con......

前端老手
昨天
8
0
一、Django基础

一、web框架分类和wsgiref模块使用介绍 web框架的本质 socket服务端 与 浏览器的通信 socket服务端功能划分: 负责与浏览器收发消息(socket通信) --> wsgiref/uWsgi/gunicorn... 根据用户访问...

ZeroBit
昨天
10
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部