搜索结果
查询Tags标签： poll，共有 58条记录-
kafka max.poll.interval.ms配置太短
max.poll.interval.ms这个应该是消费者每次去kafka拉取数据最大间隔，如果超过这个间隔，服务端会认为消费者已离线。触发rebalancedemo1 public ConsumerDemo(String topicName) {2 Properties props = new Properties();3 props.put("bootstra…
2021/10/27 6:11:39 人评论 次浏览 -
kafka max.poll.interval.ms配置太短
max.poll.interval.ms这个应该是消费者每次去kafka拉取数据最大间隔，如果超过这个间隔，服务端会认为消费者已离线。触发rebalancedemo1 public ConsumerDemo(String topicName) {2 Properties props = new Properties();3 props.put("bootstra…
2021/10/27 6:11:39 人评论 次浏览 -
找树左下角的值（递归，迭代）JAVA！
// 递归法 class Solution {private int Deep = -1;private int value = 0;public int findBottomLeftValue(TreeNode root) {value = root.val;findLeftValue(root,0);return value;}private void findLeftValue (TreeNode root,int deep) {if (root == null) return;if …
2021/10/15 22:16:41 人评论 次浏览 -
找树左下角的值（递归，迭代）JAVA！
// 递归法 class Solution {private int Deep = -1;private int value = 0;public int findBottomLeftValue(TreeNode root) {value = root.val;findLeftValue(root,0);return value;}private void findLeftValue (TreeNode root,int deep) {if (root == null) return;if …
2021/10/15 22:16:41 人评论 次浏览 -
Kafka java消费者拉取消息源码
消费者Demo1 import org.apache.kafka.clients.consumer.ConsumerRecord;2 import org.apache.kafka.clients.consumer.ConsumerRecords;3 import org.apache.kafka.clients.consumer.KafkaConsumer;4 import org.apache.kafka.common.serialization.StringDeserializer;5…
2021/10/9 11:39:54 人评论 次浏览 -
Kafka java消费者拉取消息源码
消费者Demo1 import org.apache.kafka.clients.consumer.ConsumerRecord;2 import org.apache.kafka.clients.consumer.ConsumerRecords;3 import org.apache.kafka.clients.consumer.KafkaConsumer;4 import org.apache.kafka.common.serialization.StringDeserializer;5…
2021/10/9 11:39:54 人评论 次浏览 -
网络编程
1、IO多路复用：select、poll、epoll的区别（非常重要，几乎必问，回答得越底层越好，要会使用）目前的常用的IO复用模型有三种：select，poll，epoll。select模型：说的通俗一点就是各个客户端连接的文件描述符也就是套接字，都被放到了一个集合中，调用select函数之后会…
2021/9/28 1:40:52 人评论 次浏览 -
网络编程
1、IO多路复用：select、poll、epoll的区别（非常重要，几乎必问，回答得越底层越好，要会使用）目前的常用的IO复用模型有三种：select，poll，epoll。select模型：说的通俗一点就是各个客户端连接的文件描述符也就是套接字，都被放到了一个集合中，调用select函数之后会…
2021/9/28 1:40:52 人评论 次浏览 -
linux驱动 阻塞和非阻塞IO 篇二
@上一篇介绍了linux阻塞与非阻塞的基本概念，以及应用程序的小demo和kernel层对应的api函数。那接下来就以实例来分析，如何在linux驱动层添加等待队列和轮询的方法，以及区别。 ** 一：简介 ** 在linux驱动中，存在很常见的两种设备访问模式，所以在编写驱动的时候，一定…
2021/9/14 7:04:48 人评论 次浏览 -
linux驱动 阻塞和非阻塞IO 篇二
@上一篇介绍了linux阻塞与非阻塞的基本概念，以及应用程序的小demo和kernel层对应的api函数。那接下来就以实例来分析，如何在linux驱动层添加等待队列和轮询的方法，以及区别。 ** 一：简介 ** 在linux驱动中，存在很常见的两种设备访问模式，所以在编写驱动的时候，一定…
2021/9/14 7:04:48 人评论 次浏览 -
【Linux】IO复用之poll系统调用
文章目录 一、poll 系统调用解释1. poll 函数原型解释2. struct pollfd 结构体3. events/revents 含义4. 图解 事件结构数组 二、poll 系统调用代码演示 之 监控标准输入一、poll 系统调用解释poll 没有 select 跨平台性能优越 poll 没有 epoll 性能高 故 poll 我们只做简…
2021/8/8 7:08:34 人评论 次浏览 -
【Linux】IO复用之poll系统调用
文章目录 一、poll 系统调用解释1. poll 函数原型解释2. struct pollfd 结构体3. events/revents 含义4. 图解 事件结构数组 二、poll 系统调用代码演示 之 监控标准输入一、poll 系统调用解释poll 没有 select 跨平台性能优越 poll 没有 epoll 性能高 故 poll 我们只做简…
2021/8/8 7:08:34 人评论 次浏览 -
Java——Queue（LinkedList）
目前在做题中只遇到了用LinkedList实现队列的数据结构，之后会持续更新~ 借用别人的一句话，Java不太推荐用Vector和Stack。 LinkedLsit类实现了Queue接口，因此我们可以把LinkedList当成Queue来用。创建：Queue<String> queue=new LinkedList<String>(); 添…
2021/8/2 22:38:37 人评论 次浏览 -
Java——Queue（LinkedList）
目前在做题中只遇到了用LinkedList实现队列的数据结构，之后会持续更新~ 借用别人的一句话，Java不太推荐用Vector和Stack。 LinkedLsit类实现了Queue接口，因此我们可以把LinkedList当成Queue来用。创建：Queue<String> queue=new LinkedList<String>(); 添…
2021/8/2 22:38:37 人评论 次浏览 -
spring-kafka消费者源码分析
https://blog.csdn.net/qq_26323323/article/details/84938892 这篇文章对spring-kafka消费端源码分析较为详细，可查看其customer初始化的过程。 整个初始化的开始是从@EnableKafka开始讲起的 初始化的工程归纳如下：得到一个含有KafkaListener基本信息的Endpoint，最后E…
2021/7/25 11:43:20 人评论 次浏览
