kafka基础使用

时间：2022-08-27 12:04:48浏览次数：64

标签：bin -- consul 基础 9092 kafka topic 使用

生产者
/opt/kafka/bin/kafka-console-producer.sh --broker-list kafka.service.consul:9092 --topic 0bkmonitor_15026750

消费者
/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server kafka.service.consul:9092 --topic 0bkmonitor_15026750

查询历史数据
/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server kafka.service.consul:9092 --topic 0bkmonitor_15025540 --from-beginning

标签：bin,--,consul,基础,9092,kafka,topic,使用
From： https://www.cnblogs.com/-XDD-/p/16630274.html

Nginx分布式框架详解-基础32-36nginx基础配置实例
nginx基础配置实例需求分析前面我们已经对Nginx服务器默认配置文件的结构和涉及的基本指令做了详细的阐述。通过这些指令的合理配置，我们就可以让一台Nginx服务器正常......
selenium使用cookie登录百度网页
1.首先我们先来了解下cookie的几种方法get_cookies()：获取所有cookie值get_cookie(name)：根据cookie的name值获取对应的value值get_all_cookies：删除所有cookieget_delete......
MySQL十：索引基础知识回顾
转载~1、索引简介1.1什么是索引索引是对数据库表中一列或多列的值进行排序的一种结构，可以大大提高MySQL的检索速度。索引在MySQL中也叫做key，当表中的数据量越来越大时，......
vue使用组件＜el-date-picker＞报错：Avoid mutating a prop directly since the value will
Vue使用element-ui组件库中的<el-data-picker>标签报错报以下错误，最开始我以为是props通信的问题，但后来发现是版本出现问题导致的解决办法：版本2.14.1的版本已经都不可......
JPA 入门实战(3)--Spring Boot 中使用 JPA
本文主要介绍在SpringBoot中使用JPA的方法(暂不使用spring-data-jpa)，相关的环境及软件信息如下：SpringBoot2.6.10、JPA2.2、eclipselink2.7.10。1、原生使用该......
flink cdc 使用
flinkcdc使用目前cdc产品非常多，目前我使用canal，flinkcdc（集成debezium）二者对比相对来说flinkcdc更加强大，功能很多但是有很多坑，迭代速度很快，借助flink......
D11（java基础）
D11（java基础）流概念：内存与存储设备之间传输数据的通道。流的分类按方向：输入流：将存储设备中的内容读入到内存中。输出流：将内存中的内容写入到存储设备中。......
add_argument()方法基本参数使用
selenium做web自动化时我们想要通过get打开一个页面之前就设置好一些基本参数，需要通过add_argument()方法来设置，下面以一个简单的不展示窗口为例。option=webdriver.C......
【AGC】如何使用认证服务与云数据库处理用户信息
使用场景华为AGC认证服务可以为应用快速构建安全可靠的用户认证系统，可以实现多种方式关联认证登录。而如何处理这些多种登录方式的用户信息，例如在应用中发布一个活动，哪......
node 使用 pm2-logrotate 分割pm2日志 && 停止 pm2-logroatate
使用pm2-logrotate解决pm2日志体积过大，进行分割什么是pm2-logrotate？pm2-logrotate是一个pm2的插件，可以对pm2日志进行管理，所以它的运行需要依靠pm2 安装：注：该命令......

kafka基础使用

相关文章

赞助商

阅读排行