Kafka新版消费者API示例(一)

Kafka的高阶消费者(high-level consumer)和低阶消费者(low-level consumer,底层用SimpleConsumer实现)是旧版本的consumer中的。 新版本的consumer中没有这两个概念。新版本把高阶消费者和低阶消费者整合到一块儿了,对应KafkaConsumer类的subscribe和assign方法。 建立消费者: String kafkas = "
相关文章
相关标签/搜索