kafka 全部 | 未解决 | 已解决
2019.11.01 15:17来自 sinat_30632391

Java接收kafka秒级推送数据不均匀

本应Kafka一秒推送一次数据,java这边一秒计算入库一次。可是发现如果有延迟,Kafka一秒钟推送了两次数据,大批量的数据下,java计算数据存在个别误差,请问java这边该怎么处理。双十一大屏滚动这种。
1

回答

2018.11.28 10:12来自 淺川之夏

Docker Toolbox 安装的docker,怎么在kafka容器中运用crontab

想要将kafka容器的日志定时备份,以docker可以用apt-get安装cron, 但在kafka中,docker exec 进去却是bash-4.4#,没有apt-get命令,该怎样给kafka安装 ...
0

回答

2018.11.27 08:09来自 love_yqy

kafka 消费端 处理数据比较慢,会不会出现数据积压?

如题,kafka消费端接收到数据后 要进行部分业务逻辑操作,可能会有3秒左右,处理很慢 的话,对程序有什么影响呢?新手提问, 望各位大神不吝赐教!
2

回答

2018.11.26 02:17来自 qq_35160615

flume采集kafka报错怎么解决

报错信息: Source.java:120)] Event #: 0 2018-11-23 17:59:18,995 (PollableSourceRunner-KafkaSource-kaSource) [D...
1

回答

2018.11.07 08:42来自 ghostxxy

kylin bulid cube 超时问题该如何解决

如图: ![图片说明](https://img-ask.csdn.net/upload/201811/07/1541579752_827015.png) log:org.apache...
1

回答

2018.10.15 06:04来自 前世情人 悬赏 5C

Pulsar / Kafka Topic 能分层通配吗?

比如,在Pulsar里,producer 在疯狂推送了 Topic为 mytopic的消息,消息里面包含一个表示不同消息归属主题的id,打个比方 mytopic是表示手机账单的主题消息,那个id就是手机号码 ...
1

回答

2018.09.28 14:50来自 qq_32260133

StormKafka整合问题--起始偏移量startOffsetTime

StormKafka整合问题 在项目代码中加入 spoutConfig.startOffsetTime = kafka.api.OffsetRequest.LatestTime(); ...
1

回答

2018.09.28 11:55来自 pandajc

kafka同一消费者组内的不同消费者可以订阅不同主题吗

假如有一个消费者组group,消费者组内有两个消费者c1、c2, c1订阅topic1,c2订阅topic2,那么结果是怎样的? 1、是两个消费者分别消费自己的主题; 2、还是组...
2

回答

2018.09.12 03:06来自 https://my.csdn.net/hahawo110

kafka在一台机器上模拟集群,为什么关闭一个broker,整体集群就不能消费了,求大神解答

kafka在一台机器上模拟集群,为什么关闭一个broker,整体集群就不能消费了。消费就一直卡主等待的状况。 环境: 1.一台机器运行了一个zookeeper,启动文件是在kafka/bin/zookeeper-...
1

回答

2018.08.21 03:21来自 java_66666 悬赏 5C

kafka消费者处理慢的情况下如何提高消息处理速度?不允许增加分区

如题.最近的一个面试题,说是考虑kafka理论特性.具体要求我可能有理解错误.如果各位有研究一眼看出是什么问题,谢谢给个提示. 我搜索了下,提高消费性能的有: 增加分区个数(增加消费者并行数)[不允许]; 消...
2

回答