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

Kafka的高階消費者(high-level consumer)和低階消費者(low-level consumer,底層用SimpleConsumer實現)是舊版本的consumer中的。 新版本的consumer中沒有這兩個概念。新版本把高階消費者和低階消費者整合到一塊兒了,對應KafkaConsumer類的subscribe和assign方法。 建立消費者: String kafkas = "
相關文章
相關標籤/搜索