Kafka

kafka是一种高吞吐量的分布式发布订阅消息系统,她有如下特性: 通过O(1)的磁盘数据结构提供消息的持久化,这种结构对于即使数以TB的消息存储也能够保持长时间的稳定性能...
加载中
2
回答
kafka的消费者stream iterator block,读不出消息?

rt,能够向kafka produce数据,kafka里也看得到,但是consumer却读不出数据,offset是0,程序在stream的iterator...

2016/05/28 19:39
0
回答
kafka0.9的配额能不能移植到0.8.2上啊?

想在0.8.2上实现配额,不知道能不能从0.9上移植过来。。。大佬们有没有其他实现方法?

10/12 11:05
0
回答
Kafka 集群扩张

在进行 Kafka 集群扩展时,需要对 __consumer_offsets 进行reassignment 吗 比如我现在有三个Broker, 一个top...

09/29 10:43
2
回答
kafka消费者消费速度慢

kafka1.1.0,用spring-kafka进行消费时出现消费者速度跟不上生产者,导致消息大量积压的问题 使用spring kafka进行消息的生产与...

09/21 10:24
0
回答
java 有没有API可以查询到kafka0.10.0.2版本状态为“dead"的所有消费者组?

kafka0.10.x版本以上,有没有提供专业的java api可以将kafka的状态为”dead“的所有消费者组都查询出来?

09/17 14:14
5
回答
后端开发中间件方向应该怎么规划路线呢?

目前对中间件职位,职业规划这块基本不了解,貌似仅有比较大的公司才有专门做中间件开发/研发的。 市场上大部分的职位与中间件相关的好像有大数据开发工程师、普通...

09/04 17:52
0
回答
Java使用api删除Kafka的Topic会导致Kafka无法访问已删除的log文件

AdminClient client = AdminClient.create(kafkaAdmin.getConfig()); Del...

09/07 16:46
1
回答
Kafka又遇到问题了。

2018-07-30 08:50:44,193 1814485878 [=slovedShareListener-kafka-consumer-1] IN...

07/30 08:56
4
回答
kafak主节点cpu 内存持续飙高,不回收,最后服务挂掉问题?

kafak主节点cpu 内存持续飙高,不回收,最后服务挂掉问题? [2018-08-23 07:56:11,788] INFO [GroupCoordin...

08/23 11:30
2
回答
kafka消费者处理慢的情况下如何提高消息处理速度?不允许增加分区

如题.最近的一个面试题,说是考虑kafka理论特性.具体要求我可能有理解错误.如果各位有研究一眼看出是什么问题,谢谢给个提示. 我搜索了下,提高消费性能的...

08/20 20:54
0
回答
kafka-manager 异常问题

请求页面显示:Yikes! Ask timed out on [ActorSelection[Anchor(akka://kafka-manager-sy...

08/17 13:49
1
回答
kafka客户端连接失败

1、远程服务器安装的zookeeper和kafka,在服务器上启动生产者和消费者之间是正常的可以通信 2、使用java写kafka的客户端,一直连接不上远...

08/15 14:13
0
回答
请教大神,为什么kafka根据时间戳获取offsets,当时间戳是当前时间的时候获取到offsets是null?

请教大神,为什么kafka根据时间戳获取offsets,当时间戳是当前时间的时候获取到offsets是null?使用的 java api方法是 Map<T...

08/13 15:28
4
回答
Oracle数据库数据变更同步到kafka?

现有Oracle数据库保存订单信息等数据,需要Kafka方式同步到其他系统,有没有好的方法,在尽量不改老系统的前提下,将数据库的变更实时同步到Kafka

03/15 11:55
1
回答
debezium+kafka connect中消息的before字段怎么去掉?

如何能只显示after,不显示before呢?或者我只显示某个被更新的字段,而不用把所有的字段在更新前后都显示呢?

07/16 16:04
0
回答
Kafka/ NIO问题,消息长度+消息体的协议解析问题

我们的协议是由 消息程度+包体组成,比如说 0x02, 0x09 0x08,解析成功 那么由于各种乱七八糟可能发生的原因,导致拆包粘包之类的问题,消息变成...

07/16 17:56
2
回答
Kafka0.9之后,如何获取到consuemr,topic,以及partition的offset信息

kafka0.9版本之后,consumer的消费信息不再存放在zookeeper端了,我想写java代码调到offset信息,zkClient已经不能用了...

01/25 17:12
0
回答
kafka如何通过代码触发consumerRebalance

kafka如何通过代码触发consumerRebalance

06/26 10:06
1
回答
windows下kafka1.0源码环境,日志清理报错,直接退出程序

[2018-06-19 15:08:57,934] ERROR Error while loading log dir D:\WORK\002-KAFKA...

06/19 15:17
1
回答
kafka1.0 offset自动清理后取值-1的问题

offsets.retention.minutes = 一周 log.cleanup.policy = 默认 现象: 一周内,没有任何数据进来,consu...

06/06 17:23

没有更多内容

加载失败,请刷新页面

返回顶部
顶部