大数据生态系统基础:Apache Kafka基础(三):最新kafka编程入门:Consumer

 生产者将信息输入到集群中, 那么消费者就要能从集群中取出所需要的信息。         主要的类就是: KafkaConsumer<K,V> 一、原理        Kafka的一个分区的每一个记录保持一个数值偏移。这个偏移量作为该分区内记录的惟一标识符,并表示该分区中的使用者的位置。例如,处于位置5的消费者使用偏移量0到4的记录,然后将使用偏移量5来接收记录。     消费者api提供了覆盖各
相关文章
相关标签/搜索