码迷,mamicode.com
首页 >  
搜索关键字:kafka producer    ( 4768个结果
kafka文档翻译(一)
原文来自(http://kafka.apache.org/documentation.html)本文只做简单的翻译,水平有限,仅供学习交流使用如有错误,欢迎点评指正1准备开始1.1 介绍kafka是一个分布式的,分区的,复用的日志提交服务。它以一种独特的设计方式提供消息传递系统的功能。首先让我们回顾...
分类:其他好文   时间:2015-04-17 15:27:24    阅读次数:212
Kafka生产环境中的错误。
最近写完storm实时统计pv.uv.ip的项目后,前端服务器用flume进行收集,逐步把所有的服务器都增加上。增加的差不多时。Kafka报了如下类似错误:4709[main]WARNkafka.producer.async.DefaultEventHandler-Producerequestwithcorrelationid214faileddueto[datasift,0]:kafka.commo..
分类:其他好文   时间:2015-04-16 17:53:54    阅读次数:174
Kafka生产环境中的错误。
最近写完storm实时统计pv.uv.ip的项目后,前端服务器用flume进行收集,逐步把所有的服务器都增加上。增加的差不多时。Kafka报了如下类似错误:4709[main]WARNkafka.producer.async.DefaultEventHandler-Producerequestwithcorrelationid214faileddueto[datasift,0]:kafka.commo..
分类:其他好文   时间:2015-04-16 17:51:53    阅读次数:161
spark-kafka: 错误解决1
INFO BlockManagerMaster: Registered BlockManagerException in thread "main" java.lang.NoClassDefFoundError: org/apache/spark/streaming/kafka/KafkaUtils...
分类:其他好文   时间:2015-04-13 18:12:53    阅读次数:252
linux ptheard 生产者消费者
1#include2#include3#include45pthread_mutex_tmutex;6pthread_cond_tcond_full;7pthread_cond_tcond_empty;89intg_iBufSize=0;1011void*thread_producer(void*a...
分类:系统相关   时间:2015-04-13 01:35:18    阅读次数:183
Kafka——分布式消息系统
Kafka——分布式消息系统架构ApacheKafka是2010年12月份开源的项目,采用scala语言编写,使用了多种效率优化机制,整体架构比较新颖(push/pull),更适合异构集群。设计目标:(1) 数据在磁盘上的存取代价为O(1)(2) 高吞吐率,在普通的服务器上每秒也能处理几十万条消息(...
分类:其他好文   时间:2015-04-11 13:01:35    阅读次数:163
kafka Failed to send messages after 3 tries.
我在网上搜了很多资料 说是zookeeper的问题,修改更改server.properties下的host.name,zookeeper.connect的localhost 为ip地址? 怎么也不管用 后来就单独建了一个项目,发现没有问题。结论是jar包冲突,逐个删除...
分类:其他好文   时间:2015-04-10 18:13:04    阅读次数:179
使用JMX监控Kafka
Kafka可以配置使用JMX进行运行状态的监控,既可以通过JDK自带Jconsole来观察结果,也可以通过Java API的方式来. 关于监控指标的描述,可以参考:http://kafka.apache.org/documentation.html#monitoring 开启JMX端口 修改bin/kafka-server-start.sh,添加JMX_PORT参数,添加后样...
分类:其他好文   时间:2015-04-10 18:07:24    阅读次数:363
kafka 配置
1、下载kafka? https://www.apache.org/dyn/closer.cgi?path=/kafka/0.8.2.0/kafka_2.10-0.8.2.0.tgz ? ?tar -xzf kafka_2.10-0.8.2.0.tgz ? cd kafka_2.10-0.8.2.0 2、启动服务 ? ? 启动zookeeper服务 启动...
分类:其他好文   时间:2015-04-09 17:56:44    阅读次数:101
ZeroMQ with producer-consumer
Make sure what you need ! Let's see the map below: If your data centre send many many data to you by socket ... Let's see the map again .. So you may know how to use the ...
分类:其他好文   时间:2015-04-09 17:36:26    阅读次数:257
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!