追求……

0 声望

这家伙太懒,什么都没留下

个人动态

青牧 回复 追求…… kafka消费者高级实例 中 :
哥们你找到问题了吗?
2年前
追求…… kafka消费者高级实例 发表评论:
@半兽人,我的kafka 0.8版本,4个节点的集群,一个分区。使用高级API消费的时候吞吐量只有1000每秒,这个可能是什么原因啊?以下是关键代码:
//group 代表一个消费组
        originalProps.put("group.id", "router1");

        //zk连接超时时间
        originalProps.put("zookeeper.session.timeout.ms", "40000");
        //zk同步时间
        originalProps.put("zookeeper.sync.time.ms", "200");
        //自动提交间隔时间
        originalProps.put("auto.commit.interval.ms", "10000");
        //消息日志自动偏移量,防止宕机后数据无法读取
        originalProps.put("auto.offset.reset", "smallest");
        //序列化类
        originalProps.put("serializer.class", "kafka.serializer.StringEncoder");
2年前
追求…… 我是一个线程 发表评论:
太精彩了~
3年前
追求…… jetty中文教程 发表评论:
3年前
大头 回复 追求…… 使用Kafka Connect来导入/导出数据 中 :
要确认那几个topic都在正常状态,connect-*,其所在主机都处于正常
3年前
订阅了 kafka 主题! · 3年前

(゚∀゚ )
暂时没有任何数据