Kafka Consumer API

高级API 在控制台创建发送者 创建消费者(过时API) 官方提供案例(自动维护消费情况, 新API) 高级消费者和简单的消费者有以下的区别。 1.自动/隐藏偏移管理(Offset Management ) 2.自动(简单)分区分配 3.Broker 故障转移 => 自动重新平衡 4.Consumer 故障转移 => 自动重新平衡 低级API 也叫Simple Consumer, 实际使用起来并不简单. 实现使用低级API读取指定topic,指定partition,... ... [查看更多]

Views: 551

玩转 Java 8 Stream API

先贴上几个案例,水平高超的同学可以挑战一下: 从员工集合中筛选出salary大于8000的员工,并放置到新的集合里。 统计员工的最高薪资、平均薪资、薪资之和。 将员工按薪资从高到低排序,同样薪资者年龄小者在前。 将员工按性别分类,将员工按性别和地区分类,将员工按薪资是否高于8000分为两部分。 用传统的迭代处理也不是很难,但代码就显得冗余了,跟Stream相比高下立判。 1 Stream概述 Java 8 是一个非常成功的版本,这个版本新增的Stream,配合同版本出现的 La... ... [查看更多]

Views: 538