kafka 44个问题
2018.06.06 00:12来自 maoyuanming0806 悬赏 5C
kafka1.0.0的client,生产者生产数据失败
配置: ``` Properties props = new Properties(); //broker地址 props.put("bootstrap.servers", ...
3

回答

2018.06.05 09:58来自 m0_37206072 悬赏 5C
kafka 启动异常 类似闪退问题
![图片说明](https://img-ask.csdn.net/upload/201806/05/1528164813_67679.png)前提 : 已有3台CentOS ,hadoop ,hadoop2,had...
2

回答

2018.05.12 18:08来自 Azreb 悬赏 5C
flume+kafka+hdfs 整合问题
本想搭建一个 flume+hdfs+kafka+storm+mysql 的日志实时分析和存储的系统,但是flume日志收集这块一直不通,查看flume的日志也没有报错,不知道该怎么解决了,求大家帮帮忙,贴出集群配置...
2

回答

2018.04.27 10:52来自 fjb_mxcz 悬赏 80C
如何保护zookeeper中kafka的元数据节点
我现在分别有kafka和zookeeper的集群, zookeeper我单独使用的时候自己建立的节点可以设置权限,但是kafka在zookeeper中创建的元数据节点怎么办?这些节点都是anyone权限,肯定不可能...
1

回答

2018.01.25 18:06来自 LeiXiaoTao_Java 悬赏 5C
kafka Consumer消费数据手动commit问题
Consumer设置成手动提交enable.auto.commit=false,但是在处理完消息过后没有进行consumer.commitAsync()。按照我的理解此时消费的offset是没有更新的,如果第一次p...
3

回答

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

回答

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...
2

回答

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的值,求大神帮忙看看
2

回答

共44条数据 1 3 4 ... 尾页