kafka 新版本 操作命令
kafka新版本操作命令
启动命令:
bin/kafka-server-start.sh -daemon config/server.properties创建topic
./kafka-topics.sh --create --bootstrap-server spark01:9092 --replication-factor 1 --partitions 1 --topic test2查看topic
./kafka-topics.sh --bootstrap-server spark01:9092 --list向指定topic中生产数据
./kafka-console-producer.sh --broker-list spark01:9092 --topic test2
例如:{"id":"1","name":"xiaoming","age":"20"}查看topic具体内容
./kafka-console-consumer.sh --bootstrap-server spark01:9092 --topic test2 --from-beginning创建消费者组
./kafka-console-consumer.sh --bootstrap-server spark01:9092 --topic test2 --group kafkatest查看消费者组
./kafka-consumer-groups.sh --bootstrap-server spark01:9092 --list查看消费者详情
./kafka-consumer-groups.sh --bootstrap-server spark01:9092 --describe --group kafkatest消费数据
./kafka-console-consumer.sh --bootstrap-server spark01:9092 --topic test2 --from-beginning
kafka 新版本 操作命令相关推荐
- python下载模块命令_python kafka模块操作命令集合
1.安装pykafka pip install pykafka 2.生产者 from pykafka import KafkaClient from pykafka import KafkaClien ...
- 读书笔记-kafka常用操作命令-kafka-topics.sh
1. 创建topic bin/kafka-topics.sh --zookeeper localhost:2181/kafka --create --topic topic-create --part ...
- Kafka常用操作命令总结
参考:https://www.t9vg.com/archives/438 转载于:https://www.cnblogs.com/fanta2000/p/11161855.html
- DataPipeline |《Apache Kafka实战》作者胡夕:Apache Kafka监控与调优
胡夕,<Apache Kafka实战>作者,北航计算机硕士毕业,现任某互金公司计算平台总监,曾就职于IBM.搜狗.微博等公司.国内活跃的Kafka代码贡献者. 前言 虽然目前Apache ...
- kafka 同步提交 异步_腾讯游戏工程师分享:简单理解 Kafka 的消息可靠性策略
作者:hymanzhang,腾讯 IEG 运营开发工程师 背景 部门的开发同学最近在开发一个活动的过程中,需要关注大量的应用后台逻辑,捕捉各种事件的触发.在设计时打算采用 kafka 消息队列进行业务 ...
- 简单理解 Kafka 的消息可靠性策略
作者:hymanzhang,腾讯 IEG 运营开发工程师 背景 部门的开发同学最近在开发一个活动的过程中,需要关注大量的应用后台逻辑,捕捉各种事件的触发.在设计时打算采用 kafka 消息队列进行业务 ...
- 大数据之Kafka集群安装及简单使用
目录 1.Kafka集群部署 2.Kafka常用操作命令 目录 1.Kafka集群部署 1.1.下载安装包 http://kafka.apache.org/downloads.html 在linux中 ...
- kafka 主动消费_Kafka消费组(consumer group)
在开始之前,我想花一点时间先来明确一些概念和术语,这会极大地方便我们下面的讨论.另外请原谅这文章有点长,毕竟要讨论的东西很多,虽然已然删除了很多太过细节的东西. 一. 误区澄清与概念明确 1 Kafk ...
- 《Apache Kafka 实战》读书笔记-认识Apache Kafka
<Apache Kafka 实战>读书笔记-认识Apache Kafka 作者:尹正杰 版权声明:原创作品,谢绝转载!否则将追究法律责任. 一.kafka概要设计 kafka在设计初衷就是 ...
最新文章
- jekyll 博客对搜索引擎的SEO提升方法--head中的meta标签和Jekyll SEO Tag
- 运用BT在centos下搭建一个博客论坛
- 我的WCF之旅(12):使用MSMQ进行Reliable Messaging(转载)
- UNIX学习笔记(七) 后台执行命令3 命令
- 如何安全的在不同工程间安全地迁移asset数据?三种方法
- 王者荣耀服务器维护啥时候结束,王者荣耀维护几点结束今天?11月10日维护公告...
- 994. 腐烂的橘子
- 《Scikit-Learn与TensorFlow机器学习实用指南》 第3章 分类
- python内置高阶函数求导_Python——函数式编程、高阶函数和内置函数,及
- C获取当前Linux登录的用户名
- 研磨设计模式(七)生成器模式
- 美国3月通胀见顶了吗?
- 自定义AutoTextView实现公告栏 文字3D 翻转动画
- 大数据技术_ 基础理论 之 大数据概念与应用
- execve系统调用_进程调度之 4:系统调用execve
- 2022淘宝天猫年货节超级红包攻略
- S32K系列S32K144学习笔记——UART2
- dat图片 电脑端微信_微信Dat文件解码,PC微信加密图片解密工具
- C3P0 与 DBCP 数据库连接池使用和比较
- 机器学习-贝叶斯分类算法与应用