用户组:游客
[mw_shl_code=shell,true][2019-05-21 09:45:04,120] WARN Attempting to send response via channel for which there is no ope ...
我现在做一个假设消费程序开了A B两个线程。每一个线程都是一个完整的Consumer实例。每个实例一次取10条消息 A 取了1-10 B 取 ...
我的kafka集群运行一段时间以后就会出现问题 isr就会不正常。正常情况应该是三台,但一段时间以后就会掉一台 而且掉的这一台机 ...
kafka的序列化 key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer value.deserializer = c ...
有人在生产上通过kafka直接追加数据hdfs吗,不通过storm
我安装 完kafkaoffsetmonitor后,启动正常 ,访问页面也可以,就是首页显示的消费 组名不是正确,监控不到我的组名,为什么,显 ...
我从Apache官网下载kafka_2.11-0.9.0.1.tgz,或自己编译kafka-0.9.0.1-src,然后自己虚拟机上部署单节点的Kafka时, [mw_shl_co ...
大神们,使用storm做实时计算是不是必须得使用kafka和flume收集数据然后发送给storm ?
本版积分规则 发表帖子
查看 »