kafka 50个问题
2018.01.12 19:13来自 raoping2017 悬赏 5C
kafka 在子线程消费数据,有卡顿的情况?
2个程序消费数据,一个程序在主线程消费就没这个问题,另个一个子线程消费数据,有卡顿的情况?
3

回答

2017.12.20 17:25来自 canghaitongzui 悬赏 5C
windows环境下kafka创建topic后重启就报错
[2017-12-20 17:20:15,475] WARN Found a corrupted index file due to requirement failed: Corrupt index found,...
2

回答

2017.11.28 14:25来自 zzw1531439090
springboot kafka 怎么配置 max.request.size
项目使用 springboot + kafka,有一个消息的内容比较大,出现了下面的异常 The message is 1330537 bytes when serialized which is larger t...
1

回答

2017.11.20 14:20来自 surongle123
linux 安装 librdkafka 报错
kerberos/include -I/usr/kerberos/include -I../src rdkafka_example.c -o rdkafka_example \ ...
1

回答

2017.11.15 16:13来自 u011496220
怎么通过java sdk获取kafka中的__consumer_offsets的key的值
我新建一个消费组来消费__consumer_offsets的内容,取到的key和value都是乱码,怎么解析这__consumer_offsets中的key和value的值,求大神帮忙看看
1

回答

2017.11.14 18:48来自 u011496220 悬赏 5C
求帮忙看看,kafka0.10版本怎么在java代码中获取所有的consumer group
在java代码中,我想通过topic获取到订阅了它的group,通过group获取订阅了的topic?查了好久资料了,求大神看看,给个思路。试过用zk指令,获取不到
0

回答

2017.11.12 15:58来自 luohoumei4215
kafka的生产消费模型报错
## 消费者启动报错,实在不知道哪里错了,求大神。 生产者: ./kafka-console-producer.sh --broker-list S1PA11:9092,S1PA22:9092,S1PA33:90...
0

回答

2017.10.24 10:00来自 kwb690632917
linux-docker-logstash中无法连接kafka
在docker安装的logstash-input-kafka和output-kafka都无法实现,控制台提示启动成功,但是不能生产和消费 kafka也在同一台机子的docker中。 logstash的其他插件都...
6

回答

2017.10.20 15:52来自 qq_33512300
kafka生产者发消息时无法更新元数据
十万火急,求助 kafka的broker能够正常启动,zookeeper没有问题,使用生产者发送消息失败,提示获取元数据失败 [root@newkafka2 ~]# /root/kafka2/bin/kafka-c...
3

回答

2017.10.12 16:55来自 qq_31851531 悬赏 10C
运行flume的agent,出现如下错误
我的代码: ``` agent.sources = s1 agent.channels = c1 agent.sinks = k1 agent.sources.s1.type=spooldir agent....
1

回答

共39条数据 1 3 4 尾页