搜索结果
查询Tags标签： topic，共有 206条记录-
?志收集介绍
⽇志收集 项⽬背景 每个业务系统都有⽇志，当系统出现问题时，需要通过⽇志信息定位和解决问题。 当系统机器⽐较少 时，登陆到服务器上查看即可满⾜ 当系统机器规模巨⼤，登陆到机器上查看⼏乎不现实（分布式的系 统，⼀个系统部署在⼗⼏台机器上） 解决⽅案 把机器上的⽇…
2021/11/7 23:11:56 人评论 次浏览 -
Kafka 笔记
一、什么是kafka？Kafka最初由Linkedin 公司开发，是一个分布式、分区的、多副本的、多订阅者，基于zookeeper 协调的分布式日志系统，也可以作为MQ消息系统。Linkedin 公司在2010 年贡献给了Apache基金会并成为了顶级开源项目。简单一句话，是一款分布式消息发布和订阅系…
2021/10/28 23:40:27 人评论 次浏览 -
Kafka 笔记
一、什么是kafka？Kafka最初由Linkedin 公司开发，是一个分布式、分区的、多副本的、多订阅者，基于zookeeper 协调的分布式日志系统，也可以作为MQ消息系统。Linkedin 公司在2010 年贡献给了Apache基金会并成为了顶级开源项目。简单一句话，是一款分布式消息发布和订阅系…
2021/10/28 23:40:27 人评论 次浏览 -
【Kafka】安装测试
知识点 Kafka基本架构的介绍： Broker Kafka集群包含一个或多个服务器，这种服务器被称为brokerTopic 每条发布到Kafka集群的消息都有一个类别，这个类别被称为Topic。（物理上不同Topic的消息分开存储，逻辑上一个Topic的消息虽然保存于一个或多个broker上，但用户只需指…
2021/10/25 23:40:50 人评论 次浏览 -
【Kafka】安装测试
知识点 Kafka基本架构的介绍： Broker Kafka集群包含一个或多个服务器，这种服务器被称为brokerTopic 每条发布到Kafka集群的消息都有一个类别，这个类别被称为Topic。（物理上不同Topic的消息分开存储，逻辑上一个Topic的消息虽然保存于一个或多个broker上，但用户只需指…
2021/10/25 23:40:50 人评论 次浏览 -
rocketmq消息积压监控java代码实现
最近在做彩信下发，需要下发的内容是以消息的形式存放在rocektMQ,遇上彩信消息未下发的情况，需要实时去查各topic的消息积压量 1、启动时装配监控客户端的bean @Component public class MQAdminExtConfig {private static final Logger log = LoggerFactory.getLogger(MQ…
2021/10/25 11:39:45 人评论 次浏览 -
rocketmq消息积压监控java代码实现
最近在做彩信下发，需要下发的内容是以消息的形式存放在rocektMQ,遇上彩信消息未下发的情况，需要实时去查各topic的消息积压量 1、启动时装配监控客户端的bean @Component public class MQAdminExtConfig {private static final Logger log = LoggerFactory.getLogger(MQ…
2021/10/25 11:39:45 人评论 次浏览 -
kafka3.0创建topic出现zookeeper is not a recognized option
在linux云服务器上搭建了一套kafka3.0集群，然后安装以前的创建topic指令，例如这样—— ./kafka-topics.sh --bootstrap-server master:2181,slave1:2181,slave2:2181 --replication-factor 1 --partitions 1 --topic test 然而，却出现了这样一个异常提示： Exception …
2021/10/19 23:11:32 人评论 次浏览 -
kafka3.0创建topic出现zookeeper is not a recognized option
在linux云服务器上搭建了一套kafka3.0集群，然后安装以前的创建topic指令，例如这样—— ./kafka-topics.sh --bootstrap-server master:2181,slave1:2181,slave2:2181 --replication-factor 1 --partitions 1 --topic test 然而，却出现了这样一个异常提示： Exception …
2021/10/19 23:11:32 人评论 次浏览 -
ROS通信机制(一) —— 话题(topic)与msg文件
文章目录 简述特点相关常用命令通信模型核心元素通信过程代码示例（发布者和订阅者）发布者（talker.cpp）订阅者（listener.cpp）配置 CMakeLists.txt编译和运行问题扩展 自定义消息自定义msg文件编辑配置文件执行编译修改订阅者和发布者代码编译和运行简述 话题消息通信…
2021/10/12 6:16:21 人评论 次浏览 -
ROS通信机制(一) —— 话题(topic)与msg文件
文章目录 简述特点相关常用命令通信模型核心元素通信过程代码示例（发布者和订阅者）发布者（talker.cpp）订阅者（listener.cpp）配置 CMakeLists.txt编译和运行问题扩展 自定义消息自定义msg文件编辑配置文件执行编译修改订阅者和发布者代码编译和运行简述 话题消息通信…
2021/10/12 6:16:21 人评论 次浏览 -
java二到三年经验面试题，Java中高级程序员进阶
1、PTP模型 Point-to-Point，点对点通信模型。PTP是基于队列(Queue)的，一个队列可以有多个生产者，和多个消费者。消息服务器按照收到消息的先后顺序，将消息放到队列中。队列中的每一条消息，只能由一个消费者进行消费，消费之后就会从队列中移除。需要注意的是，尽管这…
2021/10/7 9:11:12 人评论 次浏览 -
java二到三年经验面试题，Java中高级程序员进阶
1、PTP模型 Point-to-Point，点对点通信模型。PTP是基于队列(Queue)的，一个队列可以有多个生产者，和多个消费者。消息服务器按照收到消息的先后顺序，将消息放到队列中。队列中的每一条消息，只能由一个消费者进行消费，消费之后就会从队列中移除。需要注意的是，尽管这…
2021/10/7 9:11:12 人评论 次浏览 -
java函数嵌套定义，网易Java高级开发工程师视频
01 Kakfa面试疯狂轰炸44问 1.1 Kakfa基础面试篇1.Kafka的用途有哪些？使用场景如何？2.Kafka中的ISR、AR又代表什么？ISR的伸缩又指什么3.Kafka中的HW、LEO、LSO、LW等分别代表什么？4.Kafka中是怎么体现消息顺序性的？5.Kafka中的分区器、序列化器、拦截器是否了解？它们…
2021/10/7 9:11:08 人评论 次浏览 -
java函数嵌套定义，网易Java高级开发工程师视频
01 Kakfa面试疯狂轰炸44问 1.1 Kakfa基础面试篇1.Kafka的用途有哪些？使用场景如何？2.Kafka中的ISR、AR又代表什么？ISR的伸缩又指什么3.Kafka中的HW、LEO、LSO、LW等分别代表什么？4.Kafka中是怎么体现消息顺序性的？5.Kafka中的分区器、序列化器、拦截器是否了解？它们…
2021/10/7 9:11:08 人评论 次浏览
