storm与kafka集成
 请教一个问题, 我最近写的一个程序从kafka里读取数据到storm进行处理, 不知道怎么回事, 向kafka发信息, 通过kafka自带的con…
Kafka jmx监控端口问题
各位大神,求解~~ 为什么指定了jmx_port之后,kafka会再随机启一个端口监听,然后client访问jmx_port建立连接之后,通讯却用的那个随机端口? 能否指…
请教一下有没有flume和kafka的相关博客?
@FrankHui 你好,想跟你请教个问题: 我们打算用flume采集日志,然后把日志发送给kafka。最近再学习这块的知识,也看了你的kafka的相关博客感觉很不…
如何让kafka的partition分布
@FrankHui  你好,再向您请教个问题:在0.7.2版本中,如何让partition分布? 描述:有两台物理机,broker=0,1,设置partition=2。写一个topic,…
Kafka Consumer
@FrankHui 你好,想跟你请教个问题: Map<String, Integer> topicCountMap = new HashMap<String, Integer>() topicCountMap.put(topic, new…
kafka如何实时采集http请求
@FrankHui 你好,想跟你请教个问题: 我现在想实时采集Nginx收到的http请求 打算使用kafka来缓存采集到的数据 但是现在的问题就是如何才能将Nignx的…
kafka topic partition
@FrankHui 你好,想跟你请教个问题:在0.7版本中,topic和partition是什么关系? 描述:一个topic有两个partition(part0, part1),那part0和part1中…
kafka开发环境搭建
@FrankHui 你好,想跟你请教个问题:kafka开发环境搭建时,在windows下运行java项目,报:Unable to connect to zookeeper server within timeout: 6…
kafka环境搭建时报错
@FrankHui 你好,想跟你请教个问题: 问题如下: 我在按照您发表的文章学习kafka环境搭建,在启动zookeeper server :bin/zookeeper-server-start.sh…