码迷,mamicode.com
首页 >  
搜索关键字:elk kafka rsyslog flume    ( 6983个结果
服务端框架
学习进度:服务端框架进度名称描述状态ThinkPHPphp MVC框架掌握yiiphp MVC框架spring mvcjava MVC框架common.js服务端:定义应用程序使用的APInode.js服务端:commonjs的实现kafka分布式消息系统,异步处理redisKV存储hadoopHD...
分类:其他好文   时间:2015-06-02 16:44:00    阅读次数:95
haproxy
安装haproxy apt-get install haproxy 安装、配置rsyslog apt-get install rsyslog vi /etc/rsyslog.d/haproxy.conf 加入以下内容: $ModLoad imudp $UDPServerRun 514 local0.* /var/log/haproxy.log 保存, 重启...
分类:其他好文   时间:2015-06-02 15:39:33    阅读次数:235
【原创】kafka server源代码分析(二)
十四、AbstractFetcherManager.scala该scala定义了两个case类和一个抽象类。两个case类很简单:1. BrokerAndFectherId:封装了一个broker和一个fetcher的数据结构2. BrokerAndInitialOffset:封装了broker和初...
分类:其他好文   时间:2015-06-02 10:51:12    阅读次数:135
Logstash+ElasticSearch+Kibana4日志分析系统安装详解
ELK日志分析系统环境:centos6.5准备好ELK三个安装包,官网下1、安装jdk网上有的教程叫下载oracle的jdk,其实没必要,系统自带的openjdk就行了,不过需要先看下版本,1.7是不行的,要1.8以上升级到1.8先删除1.7版本#yumremove-yjava-1.7.0-openjdk然后安装1.8版本,看到下面信..
分类:其他好文   时间:2015-06-02 06:57:18    阅读次数:1305
kafka使用
pom.xml 4.0.0 kafka_demo2 kafka_demo2 0.0.1-SNAPSHOT org.apache.kafka kafka_2.10 0.8.2.1 生产消息的代码:import java.util.Proper...
分类:其他好文   时间:2015-05-31 10:52:06    阅读次数:141
分布式日志收集系统:Flume
Flume知识点:Event 是一行一行的数据 1.flume是分布式的日志收集系统,把收集来的数据传送到目的地去。 2.flume里面有个核心概念,叫做agent。agent是一个java进程,运行在日志收集节点。 3.agent里面包含3个核心组件:source、channel、sink。 3.1 source组件是专用于收集日志的,可以处理各种类型各种格式的日志数据,包括avro...
分类:Web程序   时间:2015-05-30 19:55:17    阅读次数:155
[转载] 利用flume+kafka+storm+mysql构建大数据实时系统
原文:http://mp.weixin.qq.com/s?__biz=MjM5NzAyNTE0Ng==&mid=205526269&idx=1&sn=6300502dad3e41a36f9bde8e0ba2284d&key=c468684b929d2be22eb8e183b6f92c75565b81...
分类:数据库   时间:2015-05-28 21:11:11    阅读次数:769
使用Java API创建(create),查看(describe),列举(list),删除(delete)Kafka主题(Topic)
使用Kafka的同学都知道,我们每次创建Kafka主题(Topic)的时候可以指定分区数和副本数等信息,如果将这些属性配置到server.properties文件中,以后调用Java API生成的主题将使用默认值,先改变需要使用命令bin/kafka-topics.sh --zookeeper lo...
分类:编程语言   时间:2015-05-28 17:45:49    阅读次数:458
kafkakafka_2.10-0.8.2.1+zookeeper-3.4.6 创建topic一个小问题
kafka创建topic时出现如下异常:Errorwhileexecutingtopiccommandorg.apache.zookeeper.KeeperException$NoNodeException:KeeperErrorCode=NoNodefor/brokers/idsorg.I0Itec.zkclient.exception.ZkNoNodeException:org.apache.zookeeper.KeeperException$NoNodeException:Keeper..
分类:其他好文   时间:2015-05-28 14:26:09    阅读次数:2040
【原创】kafka server源代码分析(一)
这个是Kafka server的核心包,里面的类也很多,我们还是一个一个分析一、BrokerStates.scala定义了目前一个kafka broker的7中状态 ——1. NotRunning:未运行2. Starting:启动中3. RecoveringFromUncleanShutdown:...
分类:其他好文   时间:2015-05-28 09:26:17    阅读次数:4713
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!