No less great new topic, cold pair of doom, and we will launch new consumer in specific a consumer
group, and afterwards we will try to launch producer performance, a test tool and while it will be
producing random messages.
We will try to read the details about specific consumer group.
Let me close this tab.
Let me close this tab as well.
And let's stop this consumer like this and the clear terminal here and our coffee brokers will be still
run.
OK, let's now create a new topic and I'll create a picture of two and let's say quantity of partitions
will be just three.
And let me copy this command based here.
Topic was created and now let's start the consumer into specific consumer group and the consumer will
read from this topic.
Parador, let me scroll down to the comment where we could start consumer in specific group here with
this.
And here we will read from topic pair of Doom and the group, let's say, will be better performance
group.
And let me copy this entire command.
Go here, clear Tamino and let's start consumer.
And let's basically start one more consumer in the same group, just U.S. command, Sidiq Afkham based
command.
And now in a new step, let's try to read the details about this specific group.
It will be a group like this.
Let me copy this comment and let's read details about this consumer group, Sidiq Afkham based.
And now we see three different partitions in topic of two, and there are two different consumers here,
you see two different ideas that were assigned to different partitions, partitions, zero and one were
assigned to third, the consumer.
And the last partition we decided to was assigned to second consumer.
Now, while those consumers are listening, let's try to launch a performance producer and produce the
SAMATHA just at specific rate.
Let's go to our file here and let's scroll down to Caffe Coproducer Performance Test.
And let's produce just, let's say, one thousand records at the rate of, let's say, ten records per
second and let's increase record sales and let's make it equal to 100 kilobytes like this.
And also, don't forget to adjust the topic name.
We would like to produce no messages to pair of two topics that we have created just for purposes of
the current lecture.
So let me copy this.
Come and go here.
Open up new tab.
KDDI took Afkham.
And star performers producer, while it is running, let's go to our consumers and verify whether they
are receiving messages and yes, they are.
Now, let's go to the step where we can read details about specific consumer group and let's try to
execute this command and see picture now.
And now you should see here such numbers.
And now here in this current of satcom, you'll see last committed of sales by consumers.
And you'll see that in partition zero last committed offset is forty five.
And it was committed by the consumer.
Of course, since the execution of this comment, command numbers are where I was or around this command.
And now we see that current offsets are following.
For example, in Patison with ideato currently committed offset is two hundred thirty two and it was
committed by consumers with this idea.
But in look and offset, you see actual last offset numbers for every partyism.
And at the moment Partition Zero has 210 messages.
It is lost offset.
And here you see the difference between this number and this number.
And this difference is equal to three.
And that's what lag means.
This consumer has not yet consumed last three mass and just hit this partition.
It wasn't able to consume them as quickly as they were arriving to this partition.
That's why here you see Lieke in a previous output.
You also see like numbers that were equal to 11 nine and allowing for different partitions.
Let's try to rerun this command once again and noncurrent of sets and look.
And offsets are equal and there are no less solek is zero.
And that means that all consumers have successfully read the old messages in all partitions.
In topic of two, if you want to, you could increase the numbers here in this performance producer
and produce more messages at the higher rates.
And you'll see here Hilex in this column.
But my goal for this last year was to show you what it's like and the when it appears, it appears one
consumer has not yet read all messages in specific partition.
That's all for this lecture and the next.
Let me quickly summarize what we have explored in this example.
I'll see you next.
Bye bye.