安装 pip3 install setuptools pip3 install pykafka pip3 install kafka-python 单台kafka import sys from kafka import KafkaConsumer from kafka.structs import ...
分类：
编程语言 时间：
2020-06-24 21:46:18
阅读次数：
80
插件 sup A Flutter widget which displays an image, a title, and a subtitle for errors, empty states, or just fancy custom messages. pub-rules simple yet ...
分类：
其他好文 时间：
2020-06-24 19:35:59
阅读次数：
105
消息队列 为什么用? 解耦，削峰，异步 基本模型 生产者 -> MQ -> 消费者 Kafka 十万级/s 适用于大数据领域实时计算，日志采集, ActiveMQ 万/s , RabbitMQ 万/s , RocketMQ 十万/s 造成问题及解决 1.系统可用性降低 (MQ发生故障，全崩了) 2. ...
分类：
其他好文 时间：
2020-06-24 19:24:18
阅读次数：
68
package test import org.apache.spark.sql.{DataFrame, ForeachWriter, Row, SparkSession} import org.apache.spark.sql.streaming.{ProcessingTime, Trigger} ...
分类：
数据库 时间：
2020-06-24 16:23:50
阅读次数：
132
Buggy Robot 思路：dp[inx][x][y],表示用了前inx个指令后的最小费用。 对于一个指令，我们可以选择不走或者走，其他的我们可以添加四个方向的指令与使用过指令后的dp来比较。 1 #include <iostream> 2 #include <algorithm> 3 #incl ...
分类：
其他好文 时间：
2020-06-24 16:11:34
阅读次数：
35
pt-online-schema-change 最佳实践 pt的详细步骤 Step 1: Create the new table. Step 2: Alter the new, empty table. This should be very quick, or die if the user s ...
分类：
其他好文 时间：
2020-06-24 14:29:41
阅读次数：
49
HashMap是数组+链表实现的，既然用到hash散列，那么肯定不可避免的会出现冲突问题，HashMap解决冲突的方法是拉链法，因为这里有用到数组，那么当容量不足的时候就需要进行扩容操作了，在HashMap中有个术语叫冲突，当冲突几率越来越高的时候就需要进行扩容操作了，那什么情况就叫冲突几率高呢？就 ...
分类：
其他好文 时间：
2020-06-24 11:59:48
阅读次数：
62
这是我和 sszxc 为本学期《机器人软件工程》课程所做的的课程设计，整个项目开发历时 1 个月，模型全部在 Webots2020a 中搭建完成。为完成在仿真环境下的超市自主装卸货物任务，我们设计了一套复杂的控制器进行运动控制。 1. 任务需求 如图所示，超市中 A,B,C,D 四个货架上各有12个 ...
分类：
Web程序 时间：
2020-06-24 10:31:16
阅读次数：
181
Kafka-文件管理 文件管理 保留数据是kafka的一个基本特性，kafaka不会一直保留数据，也不会等到所有消费者都读取了消息之后才删除消息。相反，kafka为每个主题配置了数据保留期限，规定数据被删除之前可以保留多长时间，或者清理数据之前可以保留的数据量大小。 因为在一个大文件里查找和删除消息 ...
分类：
其他好文 时间：
2020-06-24 00:44:34
阅读次数：
76
一、消息队列概述 消息队列（MessageQueue，简称为MQ）其本质是就是个队列，FIFO先进先出，只不过是队列中储放的主要内容是message，因而叫消息队列主要用于：不同的服务server、进程process、线程thread相互间通信二、选用消息队列的场景①异步处理②流量控制③服务解耦④发 ...
分类：
系统相关 时间：
2020-06-24 00:34:13
阅读次数：
122
