本插件是对 Flume 现有插件的扩充,主要是:
1、kafka-source,相对 flume 自带插件,升级了 kafka 依赖版本,支持更高版本的 kafka 集群,并支持自动扫描特定 topic ,无需在配置文件指定,并且自动匹配出 timestamp、level、topic、message 等常用字段;
2、kafka-channel,相对 flume 自带插件,升级了 kafka 依赖版本,支持更高版本的 kafka 集群;
3、es-sink,相对 flume 自带插件,升级了 elasticsearch 依赖版本,支持更高版本的 elasticsearch 集群。
对应版本如下:
flume1.7.0+
kafka2.12-0.10.2.1
elasticsearch6.1.0
其他版本未试验过。
flume 配置如下:
agent.sources = s1
agent.sinks = k1
agent.channels = c1
如果默认的调度器不满足要求,还可以部署自定义的调度器。并且,在整个集群中还可以同时运行多个调度器实例,通过 podSpec.schedulerName 来选择使用哪一个调度器(默认使用内置的调度器)。 开发自定义调度器 自定义调度器主要的功能是查询未调度的 Pod,按照自定义的调度策略选择新的 Node,并将其更新到 Pod 的 Node Binding 上。 比如,一个最简单的调度器可以用 sh
我正在尝试使用maven assembly插件生成zip文件程序集。我只剩下两个问题,我想知道是否有可能仅仅通过配置来解决,但作为最后的手段,我也在考虑编写自己的maven插件来扩展maven assembly插件 丢失的两块是 > 将与include模式匹配的每个依赖项放入其自己的 这是我的程序集的相关部分 这将使用
Kubernetes在设计之初就充分考虑了可扩展性,很多资源或操作都可以通过插件来自由扩展,比如认证授权、网络、Volume、容器执行引擎、调度等。
扩展插件为LSV(LocaSpaceViewer)的扩展应用中心。扩展插件会定期更新各种实用小工具,方便广大朋友使用。插件功能可以独立获取授权,购买授权后,可以在LSV软件内直接使用。授权只和账号绑定,与所用电脑无关。 坐标地址批处理工具 功能介绍 地理编码指将结构化内容转换为经纬度坐标,逆地理编码指将经纬度坐标转换成结构化地址。使用该功能模块,可以快速批量把Excel
Simditor only integrates key features and uses extensions to support some optional features. Send your repository to us! We are happy to receive your extensions! Please make your extension has the sim
插件扩展是基于 Highcharts 的基础上进行功能的二次封装,Highcharts 自 2.3 版本开始提供了多种扩展方法,利用这些方法可以很方便的扩展出自己想要的功能或图表类型。 下面是关于插件扩展相关的链接: 官方插件库 如何创建插件 提交插件到官方插件库