filebeat + kafka + logstash + ES + Kibana 整合使用 环境准备 JDK 1.8 filebeat 6.4.1 kafka 0.10.2...
这篇文章来聊一下 Kafka 的一些架构设计原理,这也是互联网公司面试时非常高频的技术考点。 Kafka 是高吞吐低延迟的高并发、高性能的消息中间件,在大数据领域有极为广泛的...
Spark on Yarn Executor Cores、Nums、Memory优化配置 设置以上三个参数,除了计算集群的节点数、节点Cores和内存大小外,还需要考虑以下...
需要自定义一个sink组件,其实很简单,只需要继承ForeachWriter,实现相关的方法即可。class RedisSink extends ForeachWriterR...