Kafka的操作 消费者组 消费位置查看

可以去使用消费者去消费Kafka中指定主题的数据消费者必须要包含在一个容器当中这个容器称之为消费者组。在之前消费者消费消息的时候并没有指定分组每一个消费者必须在一个分组里面。可以在消费消息的时候去使用--group来指定分组。但是如果没有指定分组它会自动的给你创建一个分组。可以看到存在这样一个消费者组这就是刚刚启动的消费者所在的消费者组了。消费者在启动的时候组是一定要有的。可以使用--group去指定如果不指定那么就会自动去创建。可以看到这里多了一个消费者组my-group1。消费者组就是一个容器这个容器当中可以容纳若干个消费者每一个消费者必须包含在某一个消费者组里面要么组是你指定的要么组是系统自动创建的。注意在删除消费者组的时候现在组里面没有正在运行的消费者否则会删除失败。怎么查看消费的位置在进行消费的时候可以从指定的位置进行消费使用--offset去进行指定也可以去进行查看看看消费到这个分区的什么位置了。current-offset表示对于当前分区来说消费到什么位置了log-end-offset表示这个分区中最新的offset是什么。对于0分区来说消费到8的位置了对于1分区来说消费到8的位置了对于2分区来说消费到11的位置了。这样能够查看到每一个分区消费到什么位置了。后面就是consumer的一个id信息host信息以及客户端的信息。这就是查看消费位置。现在将消费者停掉再启动一个生产者再去写消息。最终这些消息都是存在了某个partition当中。和之前不一样了0分区最新的位置是9了因为之前生产数据了。而1分区当下消费到8的位置最新的还是9lag就是一个偏移量了。这就是去查看一个分组当中的消费详情当然上面只有一个test的主题如果有多个主题也都会在这里面给列出来。