我有一个0.10的kafka集群，通过端口映射到外网，有9个生产者程序在外网向集群发布消息，开始我用kafka-client0.10的jar包时，有3 ...

m331283153 2017-6-15 9 24399

我在master启动kafka，整个集群都能启动吗 我现在是所有节点都依次手动启动 费劲

Wyy_Ck 2017-6-11 1 4990

通过HTTp协议或者长连接、队列，这几种方式都分别如何将数据放到生产者里面，然后send出去。有没有具体的代码或者方案，求大神帮 ...

丹青穆怀 2017-5-25 6 13592

[mw_shl_code=java,true] List values = new ArrayList(); /* 向 values 中添加数据 */ LinkedList ka ...

zxmit 2017-5-13 1 10763

使用kafka-manager来管理kafka集群，今天发现kafka-manager显示的每个topic的总偏移量把已经删除掉的过期数据的偏移量也算进去了 ...

m331283153 2017-4-18 2 12013

因为业务需要，我kafka要对外网提供服务。但是端口映射不出去，外网无法收发消息 advertised.host.name = ip 不行。 adver ...

lanyangkj 2017-4-13 11 11175

用Python写了个脚本，通告pykafka把数据不停的往kafka里发送，但执行一段时间后就自动退出了，也没有报错。日志部分如下： 2017 ...

grinsky 2017-4-12 3 12343

最近需要对kafka集群做流量限制，有大神知道相关的设置么。另外安全方面如何设置读取权限，现在所有用户都能读取，想改进下。

aalfalfa 2017-3-30 4 16996

我用的cdh5.9，集成的0.9.0版本的kafka，服务器是双网卡双IP，发现kafka只能监听其中一个ip的9092端口，另一个ip的端口没打开， ...

m331283153 2017-3-15 3 20374

kafka的producer放在外网的一台服务器上，通过网络将数据发布到kafka中去，这样子会不会大量发包而导致网络崩溃？

m331283153 2017-3-7 3 6082

概念含义： replication-factor表示该topic需要在不同的broker中保存几份 replication-factor设置为2, 表示在两个broker中保 ...

tntzbzc 2017-2-27 0 8840

【背景】 公司kafka集群，有几台机器被回收，由于维护疏忽，并没有做Partition转移，目前通过manager界面观察业务生产、消费正 ...

2k124 2017-2-26 5 16033

kafka.javaapi.producer.Producer和kafka.clients.producer.KafkaProducer这两个producer api有什么区别，哪一个是最新的api

m331283153 2017-2-13 3 9783

例如设置成producer每5分钟发送一次数据，求各位指点

Hentai 2016-11-16 5 13006

执行bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test报错： [2017-02-03 16:17:24,305] WARN Prop ...

Wyy_Ck 2017-2-3 2 11082

本人对kafka和storm理解比较浅显，不对之处敬请见谅 我们都知道，Consumer的配置enable.auto.commit=false设置了以后，offset ...

jnhcd 2017-1-20 3 49607

kafka版本为Kafka 0.10.0 在看kafka的官方文档时，javadoc介绍的producer和consumer都没问题(默认num.partitioner=1)。 但是 ...

jnhcd 2017-1-17 2 16252

如果kafka的topic中已经累积了很多消息，这时新组的第一个消费者开始消费该topic中的消息，这时消费者是从topic的头开始处理， ...

arsenduan 2016-12-27 1 9575

1、config/consumer.properties 这个文件有什么用？能管的住group吗？ 2、而且，我消费代码似乎写什么group都可以哦，也就是 ...

lanyangkj 2016-12-23 7 27348

1、看下边两个Api是什么区别？？同样是producer import kafka.javaapi.producer.producer import org.apache.ka ...

lanyangkj 2016-12-19 5 11728

kafka 配置好kerberos后可以正常启动，也可以创建topic 但无法往topic里写消息也无法接收 kafka版本： KAFKA-2.0.1-1.2.0.1.p0 ...

grinsky 2016-5-30 3 12449

想将队列消息定时地获取并存储到hdfs上，怎么设计及实现？ 数据源已经固定了是kafka消息队列的方式，json格式。 其实就两点， ...

师太跟我吧 2016-10-21 2 18010

我安装 完kafkaoffsetmonitor后，启动正常 ，访问页面也可以，就是首页显示的消费 组名不是正确，监控不到我的组名，为什么，显 ...

wangzhenqiang 2016-9-30 1 12972

标题可能不太明确，具体是这样的，自己模拟消息的发送过程，如图所示 假如运行到此时程序停止，当再次运行时，consumer会再次 ...

alu1105 2016-9-14 3 92768

我在网上用了好几个例子，甚至官网上消费者例子，但是都是取不出数据。 另外我发现，程序是有创建consumer group id 的，但是就 ...

pq2527991 2016-9-14 3 7285

最近在做kafka的多线程消费。 碰到一个奇怪的问题。 按照kafka的介绍，同一个group的消费者consumer，应该是处理不同的数 ...

linjikai8888 2016-8-30 3 44915

完整的报错如下： [mw_shl_code=python,true]2016-08-31 05:52:18,834 - Could not determine component version because of th ...

grinsky 2016-8-31 3 24075

使用apache官网的tar包安装kafka， 安装使用都ok。 发现使用HDP安装的kafka 在$KAFKA_HOME/bin下都有一个kafka命令 怎么才能 ...

grinsky 2016-8-31 1 7124

我想实现下面功能： 我有一个文本型的第三方数据库，有一个时间戳字段，我想通过kafka增量的从这个库中读取新数据。一次性的读 ...

lihy114 2016-4-5 8 26983