我从Apache官网下载kafka_2.11-0.9.0.1.tgz，或自己编译kafka-0.9.0.1-src，然后自己虚拟机上部署单节点的Kafka时， [mw_shl_co ...

Gatsby 2016-5-22 5 19116

在我重启kafka后，kafka已经起来了，但是生产者发送数据会报发送三次失败的错，每次我都是自己手动重启生产者。难道kafka的不会 ...

邓立辉 2016-5-9 3 19778

把flume和kafka都已经独立的部分先搭建好了。 FLume conf [mw_shl_code=xml,true]#agent section producer.sources = s p ...

神豪。 2016-4-18 1 12567

本帖最后由 pig2 于 2014-12-24 16:13 编辑 1. 背景介绍 许多公司的平台每天会产生大量的日志（一般为流式数据，如，搜索引擎 ...

redhat1986 2014-12-24 2 21784

将Hadoop中的数据，以订阅推送的方式到用户群中，有什么好的思路呢？ 推送到移动端，邮件等等其它好的思路？

aqi915 2016-2-17 1 8835

用了这么长时间的kafka了，有些问题今天还是问问吧。 kafka创建节点我知道， 删除节点也有个命令可以删除： kafka-run-class. ...

mjjian0 2015-7-7 8 54069

本帖最后由 muyannian 于 2015-11-6 21:34 编辑 Kafka将数据持久化到了硬盘上，允许你配置一定的策略对数据清理，清理的策略有 ...

muyannian 2015-11-6 0 40845

服务器处理完业务并把处理结果返回给客户端，在关闭ChannelFuture对象时总汇报异常。 代码如下： DLPResponse res ...

rsgg03 2015-4-14 2 87551

写了一个简单的kafka producer发送消息，consumer消费的例子 Producer程序如下： [mw_shl_code=java,true]public class KafkaP ...

chimes298 2015-10-10 3 44880

如何在Kafka上创建一个Topic【分享】 脚本手工创建 ./bin/kafka-topics.sh –zookeeper 192.168.2.225:2183/config/mobile ...

arsenduan 2015-9-9 2 17100

今天突然遇见了这个问题 kafka-console-producer --broker-list localhost:9092 --topic mykafka 就执行了这个命令 ...

Jame 2015-9-22 7 10605

。。。提示如下 这是为什么呢。。我的libs目录下有log4j.jar这个包。。。。

SingleDee 2015-9-11 3 12667

环境： 独立ZK：slave1:2181,slave2:2181,slave3:2181 kafka:slave1(broker1,broker2),slave2(broker3,broker4),slave3(broker ...

evababy 2015-9-6 1 9803

关于您在“kafka系列解读-文档”的帖子 楼主你好，看了你的文档我试了一下，报了一个错误 ，能告诉我这是为什么吗 [root@test- ...

desehawk 2015-9-2 0 80158

刚接触kafka，版本0.8.2 测试过程中存在几个疑问，望解答。 1、创建一个topic后，用JAVA程序正常接受，如何设置消息的超时时 ...

evababy 2015-9-2 5 13783

zk的down掉了, storm job 重启的时候报出 kafka.common.OffsetOutOfRangeException 异常

xuanxufeng 2015-8-26 4 39219

我用kafka+storm搭了个平台，现在因为storm的bolt上的逻辑有点复杂，主要跟数据库有交互，导致了延时率过高，出现很多的失败数据 ...

caiyifeng 2015-5-18 2 58679

我构建了2个topology，一个Topology(producerTopology)是用来发送数据到kafka的，另一个topology(ConsumerTopology)则是用来把ka ...

caiyifeng 2015-5-8 2 15808

我用kafka+storm搭了一个平台，遇到一个丢数据的难解问题，求各位帮忙 发送到kafka的消息条数为552860条， 在storm中调用kafka ...

caiyifeng 2015-5-7 5 15516

我搭的kafka环境能正常接收数据，我发现data目录下有个文件：recovery-point-offset-checkpoint 0 2 poc-topic 0 0 poc-top ...

caiyifeng 2015-4-30 2 16644

求问 kafka作为消息中间件怎么与hadoop集成？

冷月 2015-4-23 2 51695

我用storm应用消费了kafka的消息，奇怪的是处理成功了，但kafka的消息却能被重复消费，我把storm应用重启后，下次还是能再次读取 ...

caiyifeng 2015-4-21 5 14576

kafka继承spark streaming丢数据有朋友碰到过嘛？ 我导入了5亿条数据，hbase库里统计少3万多条。求大神指点下

唐运 2015-3-1 1 12556

kafka能做topic广播吗？ 比如放到topic1里10条数据，两个用户AB读它。A能读到10条，B也能读到10条

bioger_hit 2014-11-13 1 12942

kafka运行如下命令：kafka-server-start.sh config/server.properties & 其中配置如下：zookeeper.connect=192.168.2.10:2181/k ...

jttsai 2014-9-25 9 74570

大神们，使用storm做实时计算是不是必须得使用kafka和flume收集数据然后发送给storm ？

desehawk 2014-9-15 2 11972