创建主题观察偏移量相关数据
[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]
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）