在spark streaming读取kafka的数据中，spark streaming提供了两个接口读取kafka中的数据，分别是KafkaUtils.createDstream，KafkaUtils.createDirectStream，前者会自动把offset更新到zk中，默认会丢数据，效率低， ...
分类：
其他好文 时间：
2020-01-31 01:00:37
阅读次数：
82
本文隶属于AVR单片机教程系列。 "adc.h" "bit.h" "button.h" "buzzer.h" "dac.h" "delay.h" "ee.h" "exin.h" "exout.h" "lcd.h" "ldr.h" "led.h" "pin.h" "pot.h" "print.h" " ...
分类：
其他好文 时间：
2020-01-30 23:00:46
阅读次数：
107
超声波模块介绍： 信号连接： Vcc -- 5v Trig -- Pin 15 （Broadcom GPIO 22） Echo -- Pin 16 （Broadcom GPIO 23） Gnd -- Gnd 主要逻辑介绍： 使用wiringPi中的中断函数，wiringPiISR (23, INT_ ...
分类：
其他好文 时间：
2020-01-29 20:11:29
阅读次数：
110
状态描述： 某天下午win10更新后重启，突然无法输入PIN码解锁，后来发现整个键盘失灵。 鼓弄了几个小时才找到解决方法，记录下来： 1、解锁 打开右下角屏幕键盘，输入密码(锁屏用手机拍照，见谅) 2、查看问题原因 在左下角Windows键上鼠标右键，选择设备管理器，发现键盘下的HID Keyboa ...
分类：
其他好文 时间：
2020-01-29 20:02:44
阅读次数：
708
1、HTML5文档类型 Bootstrap 使用了一些 HTML5 元素和 CSS 属性，因此需要使用 HTML5 文档类型，开头定义如下： <!DOCTYPE html> <html> <head> <meta charset="UTF-8"> <title></title> </head> <b ...
分类：
Web程序 时间：
2020-01-28 17:42:18
阅读次数：
88
NuGet引用Microsoft.Extensions.Caching.Memory包 引用命名空间 using Microsoft.Extensions.Caching.Memory; using Microsoft.Extensions.Options; 实例化之后就可以使用. static v ...
分类：
系统相关 时间：
2020-01-27 09:42:39
阅读次数：
98
一、poll机制的作用 1.poll机制的作用 在前面的使用中断的的方式来读取按键值( "linux 中断管理(四)" )。使用这种方式读取按键，如果按键没有按下的时候，应用程序会一直处于睡眠的状态。如果想要即使按键没有按下，在一定的时间后也能返回，要实现这种功能，可以使用 。( 和`epoll`也 ...
分类：
系统相关 时间：
2020-01-26 14:37:41
阅读次数：
125
使用Kafka自带的kafka-consumer-groups.sh脚本可随意设置消费者组(consumer group)，这是0.11.0.0版本提供的新功能，设置的前提是：consumer group状态是inactive的，即不能是处于正在工作中的状态。重设位移的流程由下面3步组成：1、确定位 ...
分类：
其他好文 时间：
2020-01-25 23:42:39
阅读次数：
549
Given a non-empty 2D array grid of 0's and 1's, an island is a group of 1's (representing land) connected 4-directionally (horizontal or vertical.) Yo ...
分类：
其他好文 时间：
2020-01-24 09:22:44
阅读次数：
62
SELECT * FROM EMP -- 偏移n行 OFFSET ? ROWS -- 获取n行 FETCH NEXT ? ROWS ONLY ...
分类：
数据库 时间：
2020-01-23 09:15:05
阅读次数：
89
