kafka 只消费当前数据

Kafka是一种分布式流处理平台，可以用来处理实时数据流和批量数据。Kafka的消费者可以消费当前的数据，也可以消费过去的数据。Kafka中的消息被保存在一个可配置的时限内，消费者可以订阅特定的主题和分区，并从指定的偏移量开始消费数据。当消费者读取一个消息时，它的偏移量就会被更新，这意味着它只会消费当前的数据，而不会重复消费已经处理过的数据。如果消费者想要消费过去的数据，可以指定一个较早的偏移量来消费。