Versions Compared

Old Version 41

changes.mady.by.user PoAn Yang

Saved on

compared with

New Version 42

changes.mady.by.user PoAn Yang

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
$ bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group --state --verbose
GROUP		COORDINATOR (ID)		ASSIGNMENT-STRATEGY		STATE       GROUP-EPOCH		TARGET-ASSIGNMENT-EPOCH		#MEMBERS
my-group	localhost:61316  (0)	uniform					Stable		1				1							1

...

Code Block
$ bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group --members --verbose
GROUP			CONSUMER-ID				HOST			CLIENT-ID			#PARTITIONS		CURRENT-EPOCH	CURRENT-ASSIGNMENT			TARGET-EPOCH	TARGET-ASSIGNMENT			PROTOCOL
myconsumer-group	T4tbGKsvT7CtsxVBH5J2QQ	/127.0.0.1		consumer-group-1	4				1				my_topic:0,1;new_topic:0,1			1				my_topic:0,1;new_topic:0,1	consumer
classic-group	984f918d0921caae		/127.0.0.1		classic-group-1		4				1				my_topic:0,1;new_topic:0,1			1				my_topic:0,1;new_topic:0,1	consumerclassic

Following table lists protocol meaning.

...

Code Block
$ bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group --offsets --verbose
GROUP		TOPIC		PARTITION	LEADER-EPOCH	CURRENT-OFFSET	LOG-END-OFFSET	LAG		CONSUMER-ID										HOST			CLIENT-ID
my-group	my_topic	0			1				10				10				10		my-group-3056e339-59e1-43d8-abe3-8a9e10c53937	/127.0.0.1		consumer-test.group.CLASSIC.--offsets-2
my-group	my_topic	1			1				10				10				10		my-group-3056e339-59e1-43d8-abe3-8a9e10c53937	/127.0.0.1		consumer-test.group.CLASSIC.--offsets-2
my-group	new_topic	0			1				10				10				10		my-group-3056e339-59e1-43d8-abe3-8a9e10c53937	/127.0.0.1		consumer-test.group.CLASSIC.--offsets-2
my-group	new_topic	1			1				10				10				10		my-group-3056e339-59e1-43d8-abe3-8a9e10c53937	/127.0.0.1		consumer-test.group.CLASSIC.--offsets-2

kafka-share-groups.sh

Add a new "–verbose" option to ShareGroupCommandOptions.

--describe --state --verbose

Show the group level information. Add GROUP-EPOCH and TARGET-ASSIGNMENT-EPOCH.

Code Block
$ bin/kafka-share-groups.sh --bootstrap-server localhost:9092 --describe --group my-group --state --verbose
GROUP		COORDINATOR (ID)		STATE	GROUP-EPOCH		TARGET-ASSIGNMENT-EPOCH		#MEMBERS
my-group	localhost:61316 (0)		Stable	1				1							1

...