scottk/wlan-cloud-lib-cppkafka
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-lib-cppkafka.git synced 2025-11-08 06:23:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

Allow showing the member assignment in consumers info example

Browse Source
This commit is contained in:
Matias Fontanini
2017-06-05 19:29:11 -07:00
parent 67cad942ca
commit e741f40fbb
1 changed files with 17 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
examples/consumers_information.cpp
View File

@@ -18,20 +18,24 @@ using cppkafka::Configuration;
using cppkafka::Topic;
using cppkafka::GroupInformation;
using cppkafka::GroupMemberInformation;
using cppkafka::MemberAssignmentInformation;
namespace po = boost::program_options;
int main(int argc, char* argv[]) {
string brokers;
string group_id;
bool show_assignment = false;
po::options_description options("Options");
options.add_options()
("help,h", "produce this help message")
("brokers,b", po::value<string>(&brokers)->required(),
"the kafka broker list")
("group-id,g", po::value<string>(&group_id),
"only fetch consumer group information for the specified one")
("help,h", "produce this help message")
("brokers,b", po::value<string>(&brokers)->required(),
"the kafka broker list")
("group-id,g", po::value<string>(&group_id),
"only fetch consumer group information for the specified one")
("assignment,a", po::value<bool>(&show_assignment)->implicit_value(true),
"show topic/partition assignment for each consumer group")
;
po::variables_map vm;
@@ -74,9 +78,15 @@ int main(int argc, char* argv[]) {
}
cout << "Found the following consumers: " << endl;
for (const GroupInformation& group : groups) {
cout << "* \"" << group.get_name() << "\" having the following members: " << endl;
cout << "* \"" << group.get_name() << "\" having the following (" <<
group.get_members().size() << ") members: " << endl;
for (const GroupMemberInformation& info : group.get_members()) {
cout << " - " << info.get_member_id() << " @ " << info.get_client_host() << endl;
cout << " - " << info.get_member_id() << " @ " << info.get_client_host();
if (show_assignment) {
MemberAssignmentInformation assignment(info.get_member_assignment());
cout << " has assigned: " << assignment.get_topic_partitions();
}
cout << endl;
}
cout << endl;
}