如果现在要想将flume中的sink设置为kafka，因为在实际的开发中，可能会有若干个子系统或者若干个客户端进行flume日志采集，那么能够承受这种采集任务量的只有kafka来完成，可是需要注意一个问题，现在的kafka是采用了Kerberos认证，所以要想在flume之中去使用kafka操作，就 ...
分类：
Web程序 时间：
2020-07-03 01:11:20
阅读次数：
154
方式一： SavaAsTable 用法： df.write.mode(SaveMode.Overwrite).insertInto(table) 方式二： InsertInto 用法： df.write.mode(SaveMode.Overwrite).saveAsTable(table) 两种方式 ...
分类：
其他好文 时间：
2020-07-03 01:10:09
阅读次数：
152
定义事件： -- 定义事件，删除10天前数据，并指定每5秒执行一次；Event_syslog为事件名称 CREATE EVENT IF NOT EXISTS Event_syslog ON SCHEDULE EVERY 5 SECOND STARTS curdate() ON COMPLETION ...
分类：
数据库 时间：
2020-07-03 01:02:21
阅读次数：
148
在服务器消息推送场景中，解决方案无外乎浏览器定时询问服务器是否有新数据，另外一种则是服务器在有新数据的时候主动推送给浏览器。大概有如下几种方案： 1. 短轮询 Ajax短轮询是较常见和简单的方式。前端定时向服务端发送请求获取数据。 优点： 实现简单 缺点： 有延迟，延迟度与发送请求的间隔正相关 频繁 ...
分类：
其他好文 时间：
2020-07-03 00:50:14
阅读次数：
55
1、python中的print()语句中的end='' 为末尾end传递一个空字符串，这样print函数不会在字符串末尾添加一个换行符，而是添加一个空字符串，其实这也是一个语法要求，表示这个语句还没结束 print默认是打印一行，结尾加换行。end=''意思是末尾不换行，加空格 def goose( ...
分类：
编程语言 时间：
2020-07-03 00:36:32
阅读次数：
75
数组初始化与匿名数组 数组的声明 以下语句仅仅是声明变量a，并没有对a进行初始化成为真正的数组 int[] a; int a []; 初始化 使用new运算符创建数组 不使用new运算符 // 使用new int[] a = new int [100]; // 创建数组对象并同时赋予初始值 int[ ...
分类：
编程语言 时间：
2020-07-02 22:13:02
阅读次数：
63
Hutool工具包导出Excel文件异常 You need to add dependency of poi-ooxml to your project 出现如下异常信息 cn.hutool.core.exceptions.DependencyException: You need to add d ...
分类：
其他好文 时间：
2020-07-02 22:06:57
阅读次数：
314
后续更新双端快排，以及Arrays.sort()中的三路快排。 public void quickSort(int[] num,int start,int end){ if (start>=end){ return; } int i = start; int j = end; while(i<j){ ...
分类：
编程语言 时间：
2020-07-02 19:50:59
阅读次数：
52
参考链接 链接1 ， 链接2 ，链接3 。 0.前言： 为方便深度学习训练，我们需要多个windows的电脑可以远程访问一个linux系统的工作站（以方便在linux系统上进行深度学习训练） 前提： 1，linux系统工作站安装好基础环境。参考链接：https://www.cnblogs.com/v ...
一、为什么选择CSRedis ServiceStack.Redis 是商业版，免费版有限制； StackExchange.Redis 是免费版，但是内核在 .NETCore 运行有问题经常 Timeout，暂无法解决； CSRedis于2016年开始支持.NETCore一直迭代至今，实现了低门槛、高 ...
分类：
其他好文 时间：
2020-07-02 18:26:47
阅读次数：
65
