[大数据] Kafka内部主题__consumer

开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> 大数据 -> Kafka内部主题__consumer_offsets分析 -> 正文阅读

[大数据]Kafka内部主题__consumer_offsets分析

创建主题观察偏移量相关数据

[root@Linux122 bin]# kafka-topics.sh --zookeeper Linux122:2181/myKafka --create --topic tp_demo_06 --partitions 5 --replication-factor 1
WARNING: Due to limitations in metric names, topics with a period ('.') or underscore ('_') could collide. To avoid issues it is best to use either, but not both.
Created topic "tp_demo_06".
[root@Linux122 bin]# 
[root@Linux122 bin]# 
[root@Linux122 bin]# 
[root@Linux122 bin]# kafka-topics.sh --zookeeper Linux122:2181/myKafka --describe  --topic tp_demo_06
Topic:tp_demo_06	PartitionCount:5	ReplicationFactor:1	Configs:
	Topic: tp_demo_06	Partition: 0	Leader: 0	Replicas: 0	Isr: 0
	Topic: tp_demo_06	Partition: 1	Leader: 0	Replicas: 0	Isr: 0
	Topic: tp_demo_06	Partition: 2	Leader: 0	Replicas: 0	Isr: 0
	Topic: tp_demo_06	Partition: 3	Leader: 0	Replicas: 0	Isr: 0
	Topic: tp_demo_06	Partition: 4	Leader: 0	Replicas: 0	Isr: 0

向自己创建的主题发送消息

[root@Linux122 ~]# kafka-console-producer.sh --broker-list Linux122:9092 --topic tp_demo_06 < nm.txt

查看生产者偏移量

[root@Linux122 ~]# kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list Linux122:9092 --topic tp_demo_06 --time -1
tp_demo_06:2:12
tp_demo_06:4:12
tp_demo_06:1:12
tp_demo_06:3:12
tp_demo_06:0:12

通过上边我们发现生产的消息均匀的分布在各个分区上(上边数字表示生产者的偏移量)

通过消费者消费消息
[root@Linux122 ~]# kafka-console-consumer.sh --bootstrap-server

Linux122:9092 --topic tp_demo_06 --from-beginning
hello lagou 2
hello lagou 7
hello lagou 12
hello lagou 17
hello lagou 22
hello lagou 27

查看消费组
[root@Linux122 ~]# kafka-consumer-groups.sh --bootstrap-server Linux122:9092 --list
Note: This will not show information about old Zookeeper-based consumers.

console-consumer-83197 //该消费组是我们刚才进行消费后自动创建的消费组,这个会动态变化

查看当前消费组的信息

[root@Linux122 ~]# kafka-consumer-groups.sh --bootstrap-server Linux122:9092 --describe --group console-consumer-83197
Note: This will not show information about old Zookeeper-based consumers.

Consumer group 'console-consumer-83197' has no active members.

TOPIC                          PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG        CONSUMER-ID                                       HOST                           CLIENT-ID
tp_demo_06                     2          12              12              0          -                                                 -                              -
tp_demo_06                     4          12              12              0          -                                                 -                              -
tp_demo_06                     0          12              12              0          -                                                 -                              -
tp_demo_06                     3          12              12              0          -                                                 -                              -
tp_demo_06                     1          12              12              0          -                                                 -                              -

消费组中的消费者消费完消息后会提交偏移量给broker 即在__consumer_offsets主题中会记录

[root@Linux122 ~]# kafka-console-consumer.sh --topic __consumer_offsets --bootstrap-server Linux122:9092 --formatter "kafka.coordinator.group.GroupMetadataManager\$OffsetsMessageFormatter" --consumer.config /opt/lagou/servers/kafka_2.12-tmp/kafka_2.12-1.0.2/config/consumer.properties --from-beginning

[test-consumer-group,__consumer_offsets,30]::[OffsetMetadata[0,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,8]::[OffsetMetadata[0,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,21]::[OffsetMetadata[970,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,4]::[OffsetMetadata[0,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,27]::[OffsetMetadata[0,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,7]::[OffsetMetadata[166,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,9]::[OffsetMetadata[0,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,46]::[OffsetMetadata[81,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,25]::[OffsetMetadata[0,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,35]::[OffsetMetadata[0,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,41]::[OffsetMetadata[11,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,33]::[OffsetMetadata[838,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,23]::[OffsetMetadata[0,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,49]::[OffsetMetadata[3719,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,47]::[OffsetMetadata[14153,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,16]::[OffsetMetadata[0,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,28]::[OffsetMetadata[0,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,31]::[OffsetMetadata[2413,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,36]::[OffsetMetadata[0,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,42]::[OffsetMetadata[6,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,3]::[OffsetMetadata[0,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,18]::[OffsetMetadata[0,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,37]::[OffsetMetadata[0,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,15]::[OffsetMetadata[0,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,24]::[OffsetMetadata[14,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,38]::[OffsetMetadata[0,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,17]::[OffsetMetadata[0,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,48]::[OffsetMetadata[0,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,19]::[OffsetMetadata[0,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,11]::[OffsetMetadata[0,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,13]::[OffsetMetadata[0,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]
[test-consumer-group,__consumer_offsets,2]::[OffsetMetadata[0,NO_METADATA],CommitTime 1638368602345,ExpirationTime 1638455002345]

注意每个消费组偏移量存放分区是有计算方式
Math.abs(groupID.hashCode()) % numpatitions
通过计算消费组console-consumer-83197存放偏移量分区

String s = "console-consumer-83197";
System.out.println(Math.abs(s.hashCode())%50); //29

利用kafka-simple-consumer-shell.sh查看当前消费组偏移量数据

[root@Linux122 ~]# kafka-simple-consumer-shell.sh --topic __consumer_offsets --broker-list  Linux122:9092 --formatter "kafka.coordinator.group.GroupMetadataManager\$OffsetsMessageFormatter" --partition 29
[2021-12-01 22:44:13,917] WARN WARNING: SimpleConsumerShell is deprecated and will be dropped in a future release following 0.11.0.0. (kafka.tools.SimpleConsumerShell$)
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366926799,ExpirationTime 1638453326799]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366926799,ExpirationTime 1638453326799]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366926799,ExpirationTime 1638453326799]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366926799,ExpirationTime 1638453326799]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366926799,ExpirationTime 1638453326799]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366931787,ExpirationTime 1638453331787]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366931787,ExpirationTime 1638453331787]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366931787,ExpirationTime 1638453331787]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366931787,ExpirationTime 1638453331787]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366931787,ExpirationTime 1638453331787]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366936793,ExpirationTime 1638453336793]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366936793,ExpirationTime 1638453336793]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366936793,ExpirationTime 1638453336793]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366936793,ExpirationTime 1638453336793]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366936793,ExpirationTime 1638453336793]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366941790,ExpirationTime 1638453341790]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366941790,ExpirationTime 1638453341790]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366941790,ExpirationTime 1638453341790]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366941790,ExpirationTime 1638453341790]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366941790,ExpirationTime 1638453341790]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366946791,ExpirationTime 1638453346791]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366946791,ExpirationTime 1638453346791]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366946791,ExpirationTime 1638453346791]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366946791,ExpirationTime 1638453346791]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366946791,ExpirationTime 1638453346791]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366951793,ExpirationTime 1638453351793]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366951793,ExpirationTime 1638453351793]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366951793,ExpirationTime 1638453351793]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366951793,ExpirationTime 1638453351793]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366951793,ExpirationTime 1638453351793]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366956794,ExpirationTime 1638453356794]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366956794,ExpirationTime 1638453356794]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366956794,ExpirationTime 1638453356794]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366956794,ExpirationTime 1638453356794]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366956794,ExpirationTime 1638453356794]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366961797,ExpirationTime 1638453361797]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366961797,ExpirationTime 1638453361797]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366961797,ExpirationTime 1638453361797]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366961797,ExpirationTime 1638453361797]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366961797,ExpirationTime 1638453361797]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366966802,ExpirationTime 1638453366802]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366966802,ExpirationTime 1638453366802]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366966802,ExpirationTime 1638453366802]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366966802,ExpirationTime 1638453366802]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366966802,ExpirationTime 1638453366802]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366971802,ExpirationTime 1638453371802]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366971802,ExpirationTime 1638453371802]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366971802,ExpirationTime 1638453371802]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366971802,ExpirationTime 1638453371802]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366971802,ExpirationTime 1638453371802]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366976804,ExpirationTime 1638453376804]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366976804,ExpirationTime 1638453376804]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366976804,ExpirationTime 1638453376804]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366976804,ExpirationTime 1638453376804]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366976804,ExpirationTime 1638453376804]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366981805,ExpirationTime 1638453381805]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366981805,ExpirationTime 1638453381805]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366981805,ExpirationTime 1638453381805]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366981805,ExpirationTime 1638453381805]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366981805,ExpirationTime 1638453381805]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366986807,ExpirationTime 1638453386807]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366986807,ExpirationTime 1638453386807]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366986807,ExpirationTime 1638453386807]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366986807,ExpirationTime 1638453386807]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366986807,ExpirationTime 1638453386807]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366991809,ExpirationTime 1638453391809]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366991809,ExpirationTime 1638453391809]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366991809,ExpirationTime 1638453391809]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366991809,ExpirationTime 1638453391809]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366991809,ExpirationTime 1638453391809]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366996811,ExpirationTime 1638453396811]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366996811,ExpirationTime 1638453396811]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366996811,ExpirationTime 1638453396811]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366996811,ExpirationTime 1638453396811]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638366996811,ExpirationTime 1638453396811]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367001810,ExpirationTime 1638453401810]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367001810,ExpirationTime 1638453401810]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367001810,ExpirationTime 1638453401810]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367001810,ExpirationTime 1638453401810]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367001810,ExpirationTime 1638453401810]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367006813,ExpirationTime 1638453406813]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367006813,ExpirationTime 1638453406813]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367006813,ExpirationTime 1638453406813]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367006813,ExpirationTime 1638453406813]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367006813,ExpirationTime 1638453406813]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367011817,ExpirationTime 1638453411817]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367011817,ExpirationTime 1638453411817]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367011817,ExpirationTime 1638453411817]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367011817,ExpirationTime 1638453411817]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367011817,ExpirationTime 1638453411817]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367016818,ExpirationTime 1638453416818]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367016818,ExpirationTime 1638453416818]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367016818,ExpirationTime 1638453416818]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367016818,ExpirationTime 1638453416818]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367016818,ExpirationTime 1638453416818]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367021820,ExpirationTime 1638453421820]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367021820,ExpirationTime 1638453421820]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367021820,ExpirationTime 1638453421820]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367021820,ExpirationTime 1638453421820]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367021820,ExpirationTime 1638453421820]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367026822,ExpirationTime 1638453426822]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367026822,ExpirationTime 1638453426822]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367026822,ExpirationTime 1638453426822]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367026822,ExpirationTime 1638453426822]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367026822,ExpirationTime 1638453426822]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367031822,ExpirationTime 1638453431822]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367031822,ExpirationTime 1638453431822]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367031822,ExpirationTime 1638453431822]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367031822,ExpirationTime 1638453431822]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367031822,ExpirationTime 1638453431822]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367036826,ExpirationTime 1638453436826]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367036826,ExpirationTime 1638453436826]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367036826,ExpirationTime 1638453436826]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367036826,ExpirationTime 1638453436826]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367036826,ExpirationTime 1638453436826]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367041826,ExpirationTime 1638453441826]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367041826,ExpirationTime 1638453441826]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367041826,ExpirationTime 1638453441826]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367041826,ExpirationTime 1638453441826]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367041826,ExpirationTime 1638453441826]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367046828,ExpirationTime 1638453446828]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367046828,ExpirationTime 1638453446828]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367046828,ExpirationTime 1638453446828]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367046828,ExpirationTime 1638453446828]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367046828,ExpirationTime 1638453446828]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367051829,ExpirationTime 1638453451829]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367051829,ExpirationTime 1638453451829]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367051829,ExpirationTime 1638453451829]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367051829,ExpirationTime 1638453451829]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367051829,ExpirationTime 1638453451829]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367056831,ExpirationTime 1638453456831]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367056831,ExpirationTime 1638453456831]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367056831,ExpirationTime 1638453456831]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367056831,ExpirationTime 1638453456831]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367056831,ExpirationTime 1638453456831]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367061831,ExpirationTime 1638453461831]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367061831,ExpirationTime 1638453461831]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367061831,ExpirationTime 1638453461831]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367061831,ExpirationTime 1638453461831]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367061831,ExpirationTime 1638453461831]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367066835,ExpirationTime 1638453466835]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367066835,ExpirationTime 1638453466835]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367066835,ExpirationTime 1638453466835]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367066835,ExpirationTime 1638453466835]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367066835,ExpirationTime 1638453466835]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367071836,ExpirationTime 1638453471836]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367071836,ExpirationTime 1638453471836]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367071836,ExpirationTime 1638453471836]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367071836,ExpirationTime 1638453471836]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367071836,ExpirationTime 1638453471836]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367076838,ExpirationTime 1638453476838]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367076838,ExpirationTime 1638453476838]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367076838,ExpirationTime 1638453476838]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367076838,ExpirationTime 1638453476838]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367076838,ExpirationTime 1638453476838]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367081839,ExpirationTime 1638453481839]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367081839,ExpirationTime 1638453481839]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367081839,ExpirationTime 1638453481839]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367081839,ExpirationTime 1638453481839]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367081839,ExpirationTime 1638453481839]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367086840,ExpirationTime 1638453486840]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367086840,ExpirationTime 1638453486840]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367086840,ExpirationTime 1638453486840]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367086840,ExpirationTime 1638453486840]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367086840,ExpirationTime 1638453486840]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367091841,ExpirationTime 1638453491841]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367091841,ExpirationTime 1638453491841]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367091841,ExpirationTime 1638453491841]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367091841,ExpirationTime 1638453491841]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367091841,ExpirationTime 1638453491841]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367096841,ExpirationTime 1638453496841]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367096841,ExpirationTime 1638453496841]
[console-consumer-83197,tp_demo_06,0]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367096841,ExpirationTime 1638453496841]
[console-consumer-83197,tp_demo_06,3]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367096841,ExpirationTime 1638453496841]
[console-consumer-83197,tp_demo_06,1]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367096841,ExpirationTime 1638453496841]
[console-consumer-83197,tp_demo_06,2]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367101843,ExpirationTime 1638453501843]
[console-consumer-83197,tp_demo_06,4]::[OffsetMetadata[12,NO_METADATA],CommitTime 1638367101843,ExpirationTime 1638453501843]

大数据最新文章

实现Kafka至少消费一次

亚马逊云科技：还在苦于ETL？Zero ETL的时代

初探MapReduce

【SpringBoot框架篇】32.基于注解+redis实现

Elasticsearch：如何减少 Elasticsearch 集

Go redis操作

Redis面试题

专题五 Redis高并发场景

基于GBase8s和Calcite的多数据源查询

Redis——底层数据结构原理

加:2021-12-02 16:50:07 更:2021-12-02 16:51:01

360图书馆购物三丰科技阅读网日历万年历 2024年11日历

-2024/11/24 8:40:22-

图片自动播放器
↓图片自动播放器↓

TxT小说阅读器
↓语音阅读,小说下载,古典文学↓

一键清除垃圾
↓轻轻一点,清除系统垃圾↓

图片批量下载器
↓批量下载图片,美女图库↓

网站联系: qq:121756557 email:121756557@qq.com IT数码