码迷,mamicode.com
首页 >  
搜索关键字:kafka producer    ( 4768个结果
kafka的流量监控脚本
kafka指定topic每分钟接收到的数据总量监控 脚本: #!/bin/bash #mysql-host mysql_host='192.168.60.161' #mysql-port mysql_port='3306' #mysql-username username='root' #mysql-password #注意:此处如果mysql密码不为空,需要去下面切换一下mysql的执行代码,注...
分类:其他好文   时间:2016-05-07 07:08:40    阅读次数:2122
Flume-Kafka-Logstash-ElasticSearch-Kibana流程说明
首先说明,各工具的安装就不在这说明了,网上很多,可自行查看。 我们在这里用实例说明各个工具的配置以及最后展示的效果。 假如我们有一批tracklog日志需要用ELK实时展示出来: 一、收集日志,我们使用flume工具 在日志服务器端布置agent发往收集collect,配置如下: agent(可多个) agent.sources = s1 agent.channels...
分类:Web程序   时间:2016-05-06 16:24:34    阅读次数:1001
架构设计:系统间通信(29)——Kafka及场景应用(中2)
在本月初的写作计划中,我本来只打算粗略介绍一下Kafka(同样是因为进度原因)。但是,最近有很多朋友要求我详细讲讲Kafka的设计和使用,另外两年前我在研究Kafka准备将其应用到生产环境时,由于没有仔细理解Kafka的设计结构所导致的问题最后也还没有进行交代。所以我决定即使耽误一些时间,也要将Kafka的原理和使用场景给读者详细讨论讨论。这样,也算是对两年来自己学习和使用Kafka的一个总结。...
分类:其他好文   时间:2016-05-06 16:20:06    阅读次数:472
flume到kafka和hbase配置
# Flume test file# Listens via Avro RPC on port 41414 and dumps data received to the logagent.channels = ch-1agent.sources = src-1agent.sinks = sink-1 ...
分类:Web程序   时间:2016-05-05 19:24:54    阅读次数:854
kafka入门
问题导读: 1.zookeeper在kafka的作用是什么? 2.kafka中几乎不允许对消息进行“随机读写”的原因是什么? 3.kafka集群consumer和producer状态信息是如何保存的? 4.partitions设计的目的的根本原因是什么? 一、入门 1、简介 Kafka is a d ...
分类:其他好文   时间:2016-05-05 19:07:07    阅读次数:130
第89课:Spark Streaming on Kafka解析和安装实战
本课分2部分讲解:第一部分,讲解Kafka的概念、架构和用例场景;第二部分,讲解Kafka的安装和实战。由于时间关系,今天的课程只讲到如何用官网的例子验证Kafka的安装是否成功。后续课程会接着讲解如何集成SparkStreaming和Kafka。一、Kafka的概念、架构和用例场景http://kafka...
分类:其他好文   时间:2016-05-04 06:47:08    阅读次数:235
管理工具 Kafka Manager
管理工具 Kafka Manager 一、概述 Kafka在雅虎内部被很多团队使用,媒体团队用它做实时分析流水线,可以处理高达20Gbps(压缩数据)的峰值带宽。 为了简化开发者和服务工程师维护Kafka集群的工作,构建了一个叫做Kafka管理器的基于Web工具,叫做 Kafka Manager。这 ...
分类:其他好文   时间:2016-05-03 20:23:34    阅读次数:352
架构设计:系统间通信(28)——Kafka及场景应用(中1)
在本月初的写作计划中,我本来只打算粗略介绍一下Kafka(同样是因为进度原因)。但是,最近有很多朋友要求我详细讲讲Kafka的设计和使用,另外两年前我在研究Kafka准备将其应用到生产环境时,由于没有仔细理解Kafka的设计结构所导致的问题最后也还没有进行交代。所以我决定即使耽误一些时间,也要将Kafka的原理和使用场景给读者详细讨论讨论。这样,也算是对两年来自己在分布式思想上学习进度的一个总结。...
分类:其他好文   时间:2016-05-03 09:26:58    阅读次数:274
高吞吐量的分布式发布订阅消息系统Kafka-- 管理工具 Kafka Manager
一、概述 Kafka在雅虎内部被很多团队使用,媒体团队用它做实时分析流水线,可以处理高达20Gbps(压缩数据)的峰值带宽。 为了简化开发者和服务工程师维护Kafka集群的工作,构建了一个叫做Kafka管理器的基于Web工具,叫做 Kafka Manager。这个管理工具可以很容易地发现分布在集群中 ...
分类:其他好文   时间:2016-05-03 00:21:06    阅读次数:344
Kafka设计解析(四)- Kafka Consumer设计解析
本文转发自Jason’s Blog,原文链接 http://www.jasongj.com/2015/08/09/KafkaColumn4 摘要 本文主要介绍了Kafka High Level Consumer,Consumer Group,Consumer Rebalance,Low Level ...
分类:其他好文   时间:2016-05-02 22:51:47    阅读次数:263
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!