librdkafka
librdkafka copied to clipboard
Published
20 hours ago •
confluentinc
confluentinc
Misunderstandings about assignment time duration
Description
Hi!
I have misunderstandings about assignment to the end of a topic when using KafkaConsumer#assign. Note that we are using the RdKafka::KafkaConsumer which requires a group.id even if we do not use the subscription feature (that parameter is optional in the Java API).
It looks like the assign duration seems to take around ~1s in some cases due to some group coordination negotiation stuff.
I have questions regarding this behavior:
- The time to have the assignment completed (with the offset resolved) appears to be long (Note that we are working with only one broker).
- Do you think it could be less?
- Do you thing all repeated logs related to
coordinator queryare normal?
- Is there a way to be notified when the assignment is really completed (currently we are only aware of this in logs when there are configured)?
- Do you think that it can make sens to make the
group.idoptional withRdKafka::KafkaConsumerclass. - I see that the
RdKafka::Consumerallow to unspecified thegroup.idbut this API is commented as legacy with very old compatibility brokers: do you confirm that this API is still maintained?
How to reproduce
Code
#include <stdlib.h>
#include <cstdint>
#include <cstdlib>
#include <iostream>
#include <memory>
#include <chrono>
#include <boost/program_options.hpp>
#include "fmt/format.h"
#include "fmt/chrono.h"
#include "librdkafka/rdkafkacpp.h"
#include "spdlog/spdlog.h"
class Chrono {
const std::string chrono_name_;
const std::chrono::nanoseconds start_;
public:
Chrono(std::string&& chrono_name)
: chrono_name_{std::move(chrono_name)}, start_{std::chrono::steady_clock::now().time_since_epoch()} {}
~Chrono() {
const std::chrono::nanoseconds end = std::chrono::steady_clock::now().time_since_epoch();
spdlog::info("Chrono({}: {})", chrono_name_, (end - start_));
}
};
int main(int argc, char* argv[]) {
spdlog::set_level(spdlog::level::info);
// program options
std::string kafka_bootstrap_server;
std::string group_id;
std::string topic;
std::string debug;
std::int32_t nb_msg_2_consume;
namespace po = boost::program_options;
po::options_description desc("Allowed options");
// clang-format off
desc.add_options()
("help", "Help message")
("bootstrap-server", po::value(&kafka_bootstrap_server)->default_value("localhost:9092"), "Kafka bootstrap server.")
("group-id", po::value(&group_id)->default_value("my-app"), "Kafka group id.")
("topic", po::value(&topic), "Kafka topic to consume.")
("nb-msg", po::value(&nb_msg_2_consume)->default_value(1), "Number of message to consume.")
("debug", po::value(&debug)->default_value(""), "Kafka debug (all, ...).");
// clang-format on
po::variables_map vm;
po::store(po::parse_command_line(argc, argv, desc), vm);
if (vm.count("help")) {
std::cout << "Usage: " << argv[0] << " [options]\n";
std::cout << desc;
return 0;
}
po::notify(vm);
std::string errstr;
std::unique_ptr<RdKafka::Conf> consumer_configuration{RdKafka::Conf::create(RdKafka::Conf::CONF_GLOBAL)};
if (RdKafka::Conf::CONF_OK != consumer_configuration->set("metadata.broker.list", kafka_bootstrap_server, errstr)) {
spdlog::error("Failed to initialize metadata.broker.list with {} (rdkfka msg {})", kafka_bootstrap_server, errstr);
return EXIT_FAILURE;
}
if (RdKafka::Conf::CONF_OK != consumer_configuration->set("group.id", group_id, errstr)) {
spdlog::error("Failed to initialize group.id with {} (rdkfka msg {})", kafka_bootstrap_server, errstr);
return EXIT_FAILURE;
}
if (!debug.empty()) {
if (RdKafka::Conf::CONF_OK != consumer_configuration->set("debug", debug, errstr)) {
spdlog::error("Failed to initializedebug with {} (rdkfka msg {})", kafka_bootstrap_server, errstr);
return EXIT_FAILURE;
}
}
std::unique_ptr<RdKafka::KafkaConsumer> kafka_consumer{RdKafka::KafkaConsumer::create(consumer_configuration.get(), errstr)};
if (!kafka_consumer) {
spdlog::error("Failed to create kafka consumer (rdkfka msg {})", errstr);
return EXIT_FAILURE;
}
constexpr std::int32_t PARTITION = 0;
std::vector<RdKafka::TopicPartition*> partitions{RdKafka::TopicPartition::create(topic, PARTITION, RdKafka::Topic::OFFSET_END)};
spdlog::info("==========================================");
RdKafka::ErrorCode assign_return_code = RdKafka::ERR_NO_ERROR;
{
Chrono assign_chrono{"assign_chrono"};
assign_return_code = kafka_consumer->assign(partitions);
}
if (RdKafka::ERR_NO_ERROR != assign_return_code) {
spdlog::error("Failed to assign topic {}, {} (code: {})", topic, RdKafka::err2str(assign_return_code), assign_return_code);
return EXIT_FAILURE;
}
constexpr std::int32_t CONSUME_TIMEOUT_MS = 1000;
while (nb_msg_2_consume > 0) {
std::unique_ptr<RdKafka::Message> msg{kafka_consumer->consume(CONSUME_TIMEOUT_MS)};
if (msg->err() == RdKafka::ERR_NO_ERROR) {
spdlog::info("Receive kafka msg from offset {}", msg->offset());
--nb_msg_2_consume;
}
}
kafka_consumer->close();
return EXIT_SUCCESS;
}
Execution
my-app --bootstrap-server 172.200.0.250:9092 --topic my-topic --debug all --nb-msg 1
Logs
Extract
%7|1633443243.509|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "my-app" received op ASSIGN in state query-coord (join-state init)
...
%7|1633443244.510|OFFSET|rdkafka#consumer-1| [thrd:main]: Offset END request for my-topic [0] returned offset 112388 (112388)
Complete
%7|1633443243.509|MEMBERID|rdkafka#consumer-1| [thrd:app]: Group "my-app": updating member id "(not-set)" -> ""
%7|1633443243.509|WAKEUPFD|rdkafka#consumer-1| [thrd:app]: GroupCoordinator: Enabled low-latency ops queue wake-ups
%7|1633443243.509|BROKER|rdkafka#consumer-1| [thrd:app]: GroupCoordinator: Added new broker with NodeId -1
%7|1633443243.509|BRKMAIN|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Enter main broker thread
%7|1633443243.509|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "my-app" changed state init -> query-coord (join-state init)
%7|1633443243.509|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1633443243.509|CONNECT|rdkafka#consumer-1| [thrd:main]: Cluster connection already in progress: coordinator query
%7|1633443243.509|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443243.509|BRKMAIN|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Enter main broker thread
%7|1633443243.509|WAKEUPFD|rdkafka#consumer-1| [thrd:app]: 172.200.0.250:9092/bootstrap: Enabled low-latency ops queue wake-ups
%7|1633443243.509|BROKER|rdkafka#consumer-1| [thrd:app]: 172.200.0.250:9092/bootstrap: Added new broker with NodeId -1
%7|1633443243.509|INIT|rdkafka#consumer-1| [thrd:app]: librdkafka v1.6.1 (0x10601ff) rdkafka#consumer-1 initialized (builtin.features snappy,sasl,regex,lz4,sasl_plain,plugins, CC CXX PKGCONFIG INSTALL GNULD LDS C11THREADS LIBDL PLUGINS HDRHISTOGRAM SYSLOG SNAPPY SOCKEM CRC32C_HW, debug 0xfffff)
%7|1633443243.509|BRKMAIN|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Enter main broker thread
%7|1633443243.509|CONF|rdkafka#consumer-1| [thrd:app]: Client configuration:
%7|1633443243.509|CONF|rdkafka#consumer-1| [thrd:app]: client.software.version = 1.6.1
%7|1633443243.509|CONF|rdkafka#consumer-1| [thrd:app]: metadata.broker.list = 172.200.0.250:9092
%7|1633443243.509|CONF|rdkafka#consumer-1| [thrd:app]: debug = generic,broker,topic,metadata,feature,queue,msg,protocol,cgrp,security,fetch,interceptor,plugin,consumer,admin,eos,mock,assignor,conf,all
%7|1633443243.509|CONF|rdkafka#consumer-1| [thrd:app]: opaque = 0x1a8bb18
%7|1633443243.509|CONF|rdkafka#consumer-1| [thrd:app]: ssl_key = [redacted]
%7|1633443243.509|CONF|rdkafka#consumer-1| [thrd:app]: group.id = my-app
[2021-10-05 16:14:03.509] [info] ==========================================
%7|1633443243.509|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "my-app" received op ASSIGN in state query-coord (join-state init)
%7|1633443243.509|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "my-app": new assignment of 1 partition(s) in join-state init
%7|1633443243.509|CLEARASSIGN|rdkafka#consumer-1| [thrd:main]: No current assignment to clear
%7|1633443243.509|TOPIC|rdkafka#consumer-1| [thrd:main]: New local topic: my-topic
%7|1633443243.509|TOPPARNEW|rdkafka#consumer-1| [thrd:main]: NEW my-topic [-1] 0x7fb924001170 refcnt 0x7fb924001200 (at rd_kafka_topic_new0:465)
%7|1633443243.509|TOPPARNEW|rdkafka#consumer-1| [thrd:main]: NEW my-topic [0] 0x7fb9240016d0 refcnt 0x7fb924001760 (at rd_kafka_toppar_desired_add:627)
%7|1633443243.509|DESIRED|rdkafka#consumer-1| [thrd:main]: my-topic [0]: marking as DESIRED
%7|1633443243.509|DESIRED|rdkafka#consumer-1| [thrd:main]: my-topic [0]: adding to DESIRED list
%7|1633443243.509|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Added 1 partition(s) to assignment which now consists of 1 partition(s) where of 1 are in pending state and 0 are being queried
%7|1633443243.509|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
%7|1633443243.509|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s):
%7|1633443243.509|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: my-topic [0] offset END
%7|1633443243.509|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s):
%7|1633443243.509|DUMP_PND|rdkafka#consumer-1| [thrd:main]: my-topic [0] offset END
%7|1633443243.509|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1633443243.509|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1633443243.509|SRVPEND|rdkafka#consumer-1| [thrd:main]: Starting pending assigned partition my-topic [0] at offset END
%7|1633443243.509|BARRIER|rdkafka#consumer-1| [thrd:main]: my-topic [0]: rd_kafka_toppar_op_pause_resume:2416: new version barrier v2
%7|1633443243.509|RESUME|rdkafka#consumer-1| [thrd:main]: Resume my-topic [0] (v2)
%7|1633443243.509|BARRIER|rdkafka#consumer-1| [thrd:main]: my-topic [0]: rd_kafka_toppar_op_fetch_start:2330: new version barrier v3
%7|1633443243.509|CONSUMER|rdkafka#consumer-1| [thrd:main]: Start consuming my-topic [0] at offset END (v3)
%7|1633443243.509|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "my-app": assignment operations done in join-state init (rebalance rejoin=false)
%7|1633443243.509|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443243.509|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443243.509|OP|rdkafka#consumer-1| [thrd:main]: my-topic [0] received op PAUSE (v2) in fetch-state none (opv1)
%7|1633443243.509|RESUME|rdkafka#consumer-1| [thrd:main]: Not resuming my-topic [0]: partition is not paused by library
%7|1633443243.509|OP|rdkafka#consumer-1| [thrd:main]: my-topic [0] received op FETCH_START (v3) in fetch-state none (opv2)
[2021-10-05 16:14:03.509] [info] Chrono(assign_chrono: 114640ns)
%7|1633443243.509|FETCH|rdkafka#consumer-1| [thrd:main]: Start fetch for my-topic [0] in state none at offset END (v3)
%7|1633443243.509|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition my-topic [0] changed fetch state none -> offset-query
%7|1633443243.509|OFFSET|rdkafka#consumer-1| [thrd:main]: my-topic [0]: offset reset (at offset END) to END: update: Success
%7|1633443243.509|OFFSET|rdkafka#consumer-1| [thrd:main]: my-topic [0]: no current leader for partition: (re)starting offset query timer for offset END
%7|1633443243.509|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443243.509|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443243.509|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "my-app" received op PARTITION_JOIN in state query-coord (join-state init) for my-topic [0]
%7|1633443243.509|PARTADD|rdkafka#consumer-1| [thrd:main]: Group "my-app": add my-topic [0]
%7|1633443243.509|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443243.509|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443243.509|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443243.509|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: 172.200.0.250:9092/bootstrap: Selected for cluster connection: coordinator query (broker has 0 connection attempt(s))
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Received CONNECT op
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|STATE|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
%7|1633443244.008|BROADCAST|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: Broadcasting state change
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.008|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.008|CONNECT|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: broker in state TRY_CONNECT connecting
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|STATE|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
%7|1633443244.009|BROADCAST|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: Broadcasting state change
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Connecting to ipv4#172.200.0.250:9092 (plaintext) with socket 9
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
%7|1633443244.009|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: Group "my-app": no broker available for coordinator query: intervaled in state query-coord
%7|1633443244.009|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic my-topic [0]: timed offset query for END in state offset-query
%7|1633443244.009|OFFSET|rdkafka#consumer-1| [thrd:main]: my-topic [0]: no current leader for partition: (re)starting offset query timer for offset END
%7|1633443244.009|CONNECT|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Connected to ipv4#172.200.0.250:9092
%7|1633443244.009|CONNECTED|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Connected (#1)
%7|1633443244.009|FEATURE|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1633443244.009|STATE|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY
%7|1633443244.009|BROADCAST|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: Broadcasting state change
%7|1633443244.009|SEND|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Sent ApiVersionRequest (v3, 40 bytes @ 0, CorrId 1)
%7|1633443244.009|RECV|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Received ApiVersionResponse (v3, 358 bytes, CorrId 1, rtt 0.28ms)
%7|1633443244.009|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Broker API support:
%7|1633443244.009|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey Produce (0) Versions 0..8
%7|1633443244.009|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey Fetch (1) Versions 0..11
%7|1633443244.009|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey Offset (2) Versions 0..5
%7|1633443244.009|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey Metadata (3) Versions 0..9
%7|1633443244.009|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey LeaderAndIsr (4) Versions 0..4
%7|1633443244.009|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey StopReplica (5) Versions 0..3
%7|1633443244.009|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey UpdateMetadata (6) Versions 0..6
%7|1633443244.009|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey ControlledShutdown (7) Versions 0..3
%7|1633443244.009|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey OffsetCommit (8) Versions 0..8
%7|1633443244.009|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey OffsetFetch (9) Versions 0..7
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey FindCoordinator (10) Versions 0..3
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey JoinGroup (11) Versions 0..7
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey Heartbeat (12) Versions 0..4
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey LeaveGroup (13) Versions 0..4
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey SyncGroup (14) Versions 0..5
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey DescribeGroups (15) Versions 0..5
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey ListGroups (16) Versions 0..4
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey SaslHandshake (17) Versions 0..1
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey ApiVersion (18) Versions 0..3
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey CreateTopics (19) Versions 0..5
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey DeleteTopics (20) Versions 0..4
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey DeleteRecords (21) Versions 0..2
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey InitProducerId (22) Versions 0..3
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey OffsetForLeaderEpoch (23) Versions 0..3
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey EndTxn (26) Versions 0..1
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey DescribeAcls (29) Versions 0..2
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey CreateAcls (30) Versions 0..2
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey DeleteAcls (31) Versions 0..2
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey DescribeConfigs (32) Versions 0..3
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey AlterConfigs (33) Versions 0..1
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey AlterReplicaLogDirs (34) Versions 0..1
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey DescribeLogDirs (35) Versions 0..2
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey SaslAuthenticate (36) Versions 0..2
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey CreatePartitions (37) Versions 0..2
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey CreateDelegationToken (38) Versions 0..2
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey RenewDelegationToken (39) Versions 0..2
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey ExpireDelegationToken (40) Versions 0..2
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey DescribeDelegationToken (41) Versions 0..2
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey DeleteGroups (42) Versions 0..2
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey ElectLeadersRequest (43) Versions 0..2
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey IncrementalAlterConfigsRequest (44) Versions 0..1
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey AlterPartitionReassignmentsRequest (45) Versions 0..0
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey ListPartitionReassignmentsRequest (46) Versions 0..0
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey OffsetDeleteRequest (47) Versions 0..0
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey DescribeClientQuotasRequest (48) Versions 0..0
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: ApiKey AlterClientQuotasRequest (49) Versions 0..0
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Feature MsgVer1: Produce (2..2) supported by broker
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Feature MsgVer1: Fetch (2..2) supported by broker
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Enabling feature MsgVer1
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Feature MsgVer2: Produce (3..3) supported by broker
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Feature MsgVer2: Fetch (4..4) supported by broker
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Enabling feature MsgVer2
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Enabling feature ApiVersion
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Enabling feature BrokerGroupCoordinator
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Enabling feature BrokerBalancedConsumer
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Feature ThrottleTime: Produce (1..2) supported by broker
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Enabling feature ThrottleTime
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Feature Sasl: JoinGroup (0..0) supported by broker
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Enabling feature Sasl
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Enabling feature SaslHandshake
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Feature LZ4: FindCoordinator (0..0) supported by broker
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Enabling feature LZ4
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Feature OffsetTime: Offset (1..1) supported by broker
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Enabling feature OffsetTime
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Feature IdempotentProducer: InitProducerId (0..0) supported by broker
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Enabling feature IdempotentProducer
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Feature ZSTD: Produce (7..7) supported by broker
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Feature ZSTD: Fetch (10..10) supported by broker
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Enabling feature ZSTD
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Feature SaslAuthReq: SaslHandshake (1..1) supported by broker
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker
%7|1633443244.010|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Enabling feature SaslAuthReq
%7|1633443244.010|FEATURE|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq
%7|1633443244.010|STATE|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Broker changed state APIVERSION_QUERY -> UP
%7|1633443244.010|BROADCAST|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: Broadcasting state change
%7|1633443244.010|METADATA|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: Hinted cache of 1/1 topic(s) being queried
%7|1633443244.010|METADATA|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: Requesting metadata for 1/1 topics: connected
%7|1633443244.010|METADATA|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Request metadata for 1 topic(s): connected
%7|1633443244.010|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: 172.200.0.250:9092/bootstrap: Group "my-app": querying for coordinator: intervaled in state query-coord
%7|1633443244.010|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "my-app" changed state query-coord -> wait-coord (join-state init)
%7|1633443244.010|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1633443244.010|SEND|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Sent MetadataRequest (v4, 47 bytes @ 0, CorrId 2)
%7|1633443244.010|SEND|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Sent FindCoordinatorRequest (v2, 30 bytes @ 0, CorrId 3)
%7|1633443244.010|RECV|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Received MetadataResponse (v4, 119 bytes, CorrId 2, rtt 0.17ms)
%7|1633443244.010|METADATA|rdkafka#consumer-1| [thrd:main]: 172.200.0.250:9092/bootstrap: ===== Received metadata (for 1 requested topics): connected =====
%7|1633443244.010|METADATA|rdkafka#consumer-1| [thrd:main]: 172.200.0.250:9092/bootstrap: ClusterId: XjLLOv9dTd-cH7azTm5OhQ, ControllerId: 0
%7|1633443244.010|METADATA|rdkafka#consumer-1| [thrd:main]: 172.200.0.250:9092/bootstrap: 1 brokers, 1 topics
%7|1633443244.010|METADATA|rdkafka#consumer-1| [thrd:main]: 172.200.0.250:9092/bootstrap: Broker #0/1: 172.200.0.224:9092 NodeId 0
%7|1633443244.010|WAKEUPFD|rdkafka#consumer-1| [thrd:main]: 172.200.0.224:9092/0: Enabled low-latency ops queue wake-ups
%7|1633443244.010|BROKER|rdkafka#consumer-1| [thrd:main]: 172.200.0.224:9092/0: Added new broker with NodeId 0
%7|1633443244.010|METADATA|rdkafka#consumer-1| [thrd:main]: 172.200.0.250:9092/bootstrap: Topic #0/1: my-topic with 1 partitions
%7|1633443244.010|STATE|rdkafka#consumer-1| [thrd:main]: Topic my-topic changed state unknown -> exists
%7|1633443244.010|PARTCNT|rdkafka#consumer-1| [thrd:main]: Topic my-topic partition count changed from 0 to 1
%7|1633443244.010|METADATA|rdkafka#consumer-1| [thrd:main]: Topic my-topic partition 0 Leader 0
%7|1633443244.010|BRKDELGT|rdkafka#consumer-1| [thrd:main]: my-topic [0]: delegate to broker 172.200.0.224:9092/0 (rktp 0x7fb9240016d0, term 0, ref 4)
%7|1633443244.010|BRKMAIN|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Enter main broker thread
%7|1633443244.010|BRKDELGT|rdkafka#consumer-1| [thrd:main]: my-topic [0]: delegating to broker 172.200.0.224:9092/0 for partition with 0 messages (0 bytes) queued
%7|1633443244.010|BRKMIGR|rdkafka#consumer-1| [thrd:main]: Migrating topic my-topic [0] 0x7fb9240016d0 from (none) to 172.200.0.224:9092/0 (sending PARTITION_JOIN to 172.200.0.224:9092/0)
%7|1633443244.010|METADATA|rdkafka#consumer-1| [thrd:main]: 172.200.0.250:9092/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1633443244.010|TOPBRK|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Topic my-topic [0]: joining broker (rktp 0x7fb9240016d0, 0 message(s) queued)
%7|1633443244.010|BROADCAST|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: Broadcasting state change
%7|1633443244.010|CLUSTERID|rdkafka#consumer-1| [thrd:main]: 172.200.0.250:9092/bootstrap: ClusterId update "" -> "XjLLOv9dTd-cH7azTm5OhQ"
%7|1633443244.010|RECV|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Received FindCoordinatorResponse (v2, 35 bytes, CorrId 3, rtt 0.32ms)
%7|1633443244.010|CONTROLLERID|rdkafka#consumer-1| [thrd:main]: 172.200.0.250:9092/bootstrap: ControllerId update -1 -> 0
%7|1633443244.010|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1633443244.010|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: 172.200.0.250:9092/bootstrap: Group "my-app" coordinator is 172.200.0.224:9092 id 0
%7|1633443244.010|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: Group "my-app" changing coordinator -1 -> 0
%7|1633443244.010|COORDSET|rdkafka#consumer-1| [thrd:main]: Group "my-app" coordinator set to broker 172.200.0.224:9092/0
%7|1633443244.010|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "my-app" changed state wait-coord -> wait-broker-transport (join-state init)
%7|1633443244.010|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1633443244.010|NODENAME|rdkafka#consumer-1| [thrd:main]: GroupCoordinator: Broker nodename changed from "" to "172.200.0.224:9092"
%7|1633443244.010|NODEID|rdkafka#consumer-1| [thrd:main]: GroupCoordinator: Broker nodeid changed from -1 to 0
%7|1633443244.010|CONNECT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Received CONNECT op
%7|1633443244.010|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state INIT -> TRY_CONNECT
%7|1633443244.010|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1633443244.010|CGRPQUERY|rdkafka#consumer-1| [thrd:main]: 172.200.0.250:9092/bootstrap: Group "my-app": querying for coordinator: intervaled in state wait-broker-transport
%7|1633443244.010|FAIL|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: 172.200.0.224:9092: Closing connection due to nodename change (after 0ms in state TRY_CONNECT) (_TRANSPORT)
%7|1633443244.010|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state TRY_CONNECT -> DOWN
%7|1633443244.010|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1633443244.010|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Purging bufq with 0 buffers
%7|1633443244.010|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Purging bufq with 0 buffers
%7|1633443244.010|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Updating 0 buffers on connection reset
%7|1633443244.010|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state DOWN -> INIT
%7|1633443244.010|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1633443244.010|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state INIT -> TRY_CONNECT
%7|1633443244.010|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1633443244.010|CONNECT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: broker in state TRY_CONNECT connecting
%7|1633443244.010|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state TRY_CONNECT -> CONNECT
%7|1633443244.010|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1633443244.010|SEND|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Sent FindCoordinatorRequest (v2, 30 bytes @ 0, CorrId 4)
%7|1633443244.010|RECV|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Received FindCoordinatorResponse (v2, 35 bytes, CorrId 4, rtt 0.09ms)
%7|1633443244.010|CONNECT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Connecting to ipv4#172.200.0.224:9092 (plaintext) with socket 12
%7|1633443244.010|CGRPCOORD|rdkafka#consumer-1| [thrd:main]: 172.200.0.250:9092/bootstrap: Group "my-app" coordinator is 172.200.0.224:9092 id 0
%7|1633443244.010|CONNECT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Connected to ipv4#172.200.0.224:9092
%7|1633443244.010|CONNECTED|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Connected (#1)
%7|1633443244.010|FEATURE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1633443244.010|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state CONNECT -> APIVERSION_QUERY
%7|1633443244.010|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1633443244.010|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Sent ApiVersionRequest (v3, 40 bytes @ 0, CorrId 1)
%7|1633443244.011|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Received ApiVersionResponse (v3, 358 bytes, CorrId 1, rtt 0.49ms)
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Broker API support:
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey Produce (0) Versions 0..8
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey Fetch (1) Versions 0..11
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey Offset (2) Versions 0..5
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey Metadata (3) Versions 0..9
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey LeaderAndIsr (4) Versions 0..4
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey StopReplica (5) Versions 0..3
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey UpdateMetadata (6) Versions 0..6
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey ControlledShutdown (7) Versions 0..3
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey OffsetCommit (8) Versions 0..8
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey OffsetFetch (9) Versions 0..7
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey FindCoordinator (10) Versions 0..3
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey JoinGroup (11) Versions 0..7
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey Heartbeat (12) Versions 0..4
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey LeaveGroup (13) Versions 0..4
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey SyncGroup (14) Versions 0..5
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DescribeGroups (15) Versions 0..5
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey ListGroups (16) Versions 0..4
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey SaslHandshake (17) Versions 0..1
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey ApiVersion (18) Versions 0..3
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey CreateTopics (19) Versions 0..5
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DeleteTopics (20) Versions 0..4
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DeleteRecords (21) Versions 0..2
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey InitProducerId (22) Versions 0..3
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey OffsetForLeaderEpoch (23) Versions 0..3
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey EndTxn (26) Versions 0..1
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DescribeAcls (29) Versions 0..2
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey CreateAcls (30) Versions 0..2
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DeleteAcls (31) Versions 0..2
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DescribeConfigs (32) Versions 0..3
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey AlterConfigs (33) Versions 0..1
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey AlterReplicaLogDirs (34) Versions 0..1
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DescribeLogDirs (35) Versions 0..2
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey SaslAuthenticate (36) Versions 0..2
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey CreatePartitions (37) Versions 0..2
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey CreateDelegationToken (38) Versions 0..2
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey RenewDelegationToken (39) Versions 0..2
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey ExpireDelegationToken (40) Versions 0..2
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DescribeDelegationToken (41) Versions 0..2
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DeleteGroups (42) Versions 0..2
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey ElectLeadersRequest (43) Versions 0..2
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey IncrementalAlterConfigsRequest (44) Versions 0..1
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey AlterPartitionReassignmentsRequest (45) Versions 0..0
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey ListPartitionReassignmentsRequest (46) Versions 0..0
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey OffsetDeleteRequest (47) Versions 0..0
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey DescribeClientQuotasRequest (48) Versions 0..0
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: ApiKey AlterClientQuotasRequest (49) Versions 0..0
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature MsgVer1: Produce (2..2) supported by broker
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature MsgVer1: Fetch (2..2) supported by broker
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature MsgVer1
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature MsgVer2: Produce (3..3) supported by broker
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature MsgVer2: Fetch (4..4) supported by broker
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature MsgVer2
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature ApiVersion
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature BrokerGroupCoordinator
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature BrokerBalancedConsumer
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature ThrottleTime: Produce (1..2) supported by broker
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature ThrottleTime
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature Sasl: JoinGroup (0..0) supported by broker
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature Sasl
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature SaslHandshake
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature LZ4: FindCoordinator (0..0) supported by broker
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature LZ4
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature OffsetTime: Offset (1..1) supported by broker
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature OffsetTime
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature IdempotentProducer: InitProducerId (0..0) supported by broker
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature IdempotentProducer
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature ZSTD: Produce (7..7) supported by broker
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature ZSTD: Fetch (10..10) supported by broker
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature ZSTD
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature SaslAuthReq: SaslHandshake (1..1) supported by broker
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker
%7|1633443244.011|APIVERSION|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Enabling feature SaslAuthReq
%7|1633443244.011|FEATURE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq
%7|1633443244.011|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state APIVERSION_QUERY -> UP
%7|1633443244.011|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1633443244.011|METADATA|rdkafka#consumer-1| [thrd:GroupCoordinator]: Skipping metadata refresh of 1 topic(s): connected: already being requested
%7|1633443244.011|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "my-app" changed state wait-broker-transport -> up (join-state init)
%7|1633443244.011|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1633443244.011|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0)
%7|1633443244.011|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s):
%7|1633443244.011|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: my-topic [0] offset END
%7|1633443244.011|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1633443244.011|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1633443244.011|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1633443244.011|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "my-app": assignment operations done in join-state init (rebalance rejoin=false)
%7|1633443244.509|OFFSET|rdkafka#consumer-1| [thrd:main]: Topic my-topic [0]: timed offset query for END in state offset-query
%7|1633443244.509|OFFREQ|rdkafka#consumer-1| [thrd:main]: 172.200.0.224:9092/0: Partition my-topic [0]: querying for logical offset END (opv 3)
%7|1633443244.509|OFFSET|rdkafka#consumer-1| [thrd:main]: 172.200.0.224:9092/0: OffsetRequest (v0, opv 0) for 1 topic(s) and 1 partition(s)
%7|1633443244.509|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition my-topic [0] changed fetch state offset-query -> offset-wait
%7|1633443244.509|STATE|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Broker changed state INIT -> TRY_CONNECT
%7|1633443244.509|BROADCAST|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: Broadcasting state change
%7|1633443244.509|CONNECT|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: broker in state TRY_CONNECT connecting
%7|1633443244.509|STATE|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Broker changed state TRY_CONNECT -> CONNECT
%7|1633443244.509|BROADCAST|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: Broadcasting state change
%7|1633443244.509|CONNECT|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Connecting to ipv4#172.200.0.224:9092 (plaintext) with socket 13
%7|1633443244.509|CONNECT|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Connected to ipv4#172.200.0.224:9092
%7|1633443244.509|CONNECTED|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Connected (#1)
%7|1633443244.509|FEATURE|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1633443244.509|STATE|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Broker changed state CONNECT -> APIVERSION_QUERY
%7|1633443244.509|BROADCAST|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: Broadcasting state change
%7|1633443244.509|SEND|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Sent ApiVersionRequest (v3, 40 bytes @ 0, CorrId 1)
%7|1633443244.510|RECV|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Received ApiVersionResponse (v3, 358 bytes, CorrId 1, rtt 0.30ms)
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Broker API support:
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey Produce (0) Versions 0..8
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey Fetch (1) Versions 0..11
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey Offset (2) Versions 0..5
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey Metadata (3) Versions 0..9
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey LeaderAndIsr (4) Versions 0..4
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey StopReplica (5) Versions 0..3
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey UpdateMetadata (6) Versions 0..6
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey ControlledShutdown (7) Versions 0..3
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey OffsetCommit (8) Versions 0..8
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey OffsetFetch (9) Versions 0..7
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey FindCoordinator (10) Versions 0..3
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey JoinGroup (11) Versions 0..7
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey Heartbeat (12) Versions 0..4
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey LeaveGroup (13) Versions 0..4
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey SyncGroup (14) Versions 0..5
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey DescribeGroups (15) Versions 0..5
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey ListGroups (16) Versions 0..4
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey SaslHandshake (17) Versions 0..1
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey ApiVersion (18) Versions 0..3
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey CreateTopics (19) Versions 0..5
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey DeleteTopics (20) Versions 0..4
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey DeleteRecords (21) Versions 0..2
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey InitProducerId (22) Versions 0..3
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey OffsetForLeaderEpoch (23) Versions 0..3
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey EndTxn (26) Versions 0..1
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey DescribeAcls (29) Versions 0..2
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey CreateAcls (30) Versions 0..2
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey DeleteAcls (31) Versions 0..2
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey DescribeConfigs (32) Versions 0..3
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey AlterConfigs (33) Versions 0..1
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey AlterReplicaLogDirs (34) Versions 0..1
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey DescribeLogDirs (35) Versions 0..2
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey SaslAuthenticate (36) Versions 0..2
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey CreatePartitions (37) Versions 0..2
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey CreateDelegationToken (38) Versions 0..2
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey RenewDelegationToken (39) Versions 0..2
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey ExpireDelegationToken (40) Versions 0..2
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey DescribeDelegationToken (41) Versions 0..2
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey DeleteGroups (42) Versions 0..2
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey ElectLeadersRequest (43) Versions 0..2
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey IncrementalAlterConfigsRequest (44) Versions 0..1
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey AlterPartitionReassignmentsRequest (45) Versions 0..0
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey ListPartitionReassignmentsRequest (46) Versions 0..0
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey OffsetDeleteRequest (47) Versions 0..0
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey DescribeClientQuotasRequest (48) Versions 0..0
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: ApiKey AlterClientQuotasRequest (49) Versions 0..0
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Feature MsgVer1: Produce (2..2) supported by broker
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Feature MsgVer1: Fetch (2..2) supported by broker
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Enabling feature MsgVer1
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Feature MsgVer2: Produce (3..3) supported by broker
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Feature MsgVer2: Fetch (4..4) supported by broker
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Enabling feature MsgVer2
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Enabling feature ApiVersion
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Enabling feature BrokerGroupCoordinator
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Enabling feature BrokerBalancedConsumer
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Feature ThrottleTime: Produce (1..2) supported by broker
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Enabling feature ThrottleTime
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Feature Sasl: JoinGroup (0..0) supported by broker
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Enabling feature Sasl
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Enabling feature SaslHandshake
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Feature LZ4: FindCoordinator (0..0) supported by broker
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Enabling feature LZ4
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Feature OffsetTime: Offset (1..1) supported by broker
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Enabling feature OffsetTime
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Feature IdempotentProducer: InitProducerId (0..0) supported by broker
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Enabling feature IdempotentProducer
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Feature ZSTD: Produce (7..7) supported by broker
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Feature ZSTD: Fetch (10..10) supported by broker
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Enabling feature ZSTD
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Feature SaslAuthReq: SaslHandshake (1..1) supported by broker
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker
%7|1633443244.510|APIVERSION|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Enabling feature SaslAuthReq
%7|1633443244.510|FEATURE|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq
%7|1633443244.510|STATE|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Broker changed state APIVERSION_QUERY -> UP
%7|1633443244.510|BROADCAST|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: Broadcasting state change
%7|1633443244.510|METADATA|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: Skipping metadata refresh of 1 topic(s): connected: already being requested
%7|1633443244.510|SEND|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Sent OffsetRequest (v0, 70 bytes @ 0, CorrId 2)
%7|1633443244.510|RECV|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Received OffsetResponse (v0, 47 bytes, CorrId 2, rtt 0.26ms)
%7|1633443244.510|OFFSET|rdkafka#consumer-1| [thrd:main]: 172.200.0.224:9092/0: Offset reply for topic my-topic [0] (v3 vs v3)
%7|1633443244.510|OFFSET|rdkafka#consumer-1| [thrd:main]: Offset END request for my-topic [0] returned offset 112388 (112388)
%7|1633443244.510|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition my-topic [0] changed fetch state offset-wait -> active
%7|1633443244.510|FETCH|rdkafka#consumer-1| [thrd:main]: Partition my-topic [0] start fetching at offset 112388
%7|1633443244.510|WAKEUP|rdkafka#consumer-1| [thrd:main]: 172.200.0.224:9092/0: Wake-up
%7|1633443244.510|FETCHDEC|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: Topic my-topic [0]: fetch decide: updating to version 3 (was 0) at offset 112388 (was 0)
%7|1633443244.510|FETCH|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Topic my-topic [0] in state active at offset 112388 (0/100000 msgs, 0/65536 kb queued, opv 3) is fetchable
%7|1633443244.510|FETCHADD|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Added my-topic [0] to fetch list (1 entries, opv 3, 0 messages queued): fetchable
%7|1633443244.510|FETCH|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Fetch topic my-topic [0] at offset 112388 (v3)
%7|1633443244.510|FETCH|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Fetch 1/1/1 toppar(s)
%7|1633443244.510|SEND|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Sent FetchRequest (v11, 109 bytes @ 0, CorrId 3)
%7|1633443244.880|RECV|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Received FetchResponse (v11, 1264 bytes, CorrId 3, rtt 369.83ms)
%7|1633443244.880|FETCH|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Topic my-topic [0] MessageSet size 1183, error "Success", MaxOffset 112389, LSO 112389, Ver 3/3
%7|1633443244.880|CONSUME|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Enqueue 1 message(s) (925 bytes, 1 ops) on my-topic [0] fetch queue (qlen 1, v3, last_offset 112388, 0 ctrl msgs, uncompressed)
%7|1633443244.880|FETCH|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Fetch topic my-topic [0] at offset 112389 (v3)
%7|1633443244.880|FETCH|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Fetch 1/1/1 toppar(s)
%7|1633443244.880|SEND|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Sent FetchRequest (v11, 109 bytes @ 0, CorrId 4)
[2021-10-05 16:14:04.880] [info] Receive kafka msg from offset 112388
%7|1633443244.880|CLOSE|rdkafka#consumer-1| [thrd:app]: Closing consumer
%7|1633443244.880|CLOSE|rdkafka#consumer-1| [thrd:app]: Waiting for close events
%7|1633443244.880|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "my-app" received op TERMINATE in state up (join-state init)
%7|1633443244.880|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Terminating group "my-app" in state up with 1 partition(s)
%7|1633443244.880|CLEARASSIGN|rdkafka#consumer-1| [thrd:main]: Clearing current assignment of 1 partition(s)
%7|1633443244.880|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=1, wait_stop_cnt=0)
%7|1633443244.880|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1633443244.880|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1633443244.880|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1633443244.880|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 1 partition(s):
%7|1633443244.880|DUMP_REM|rdkafka#consumer-1| [thrd:main]: my-topic [0] offset END
%7|1633443244.880|BARRIER|rdkafka#consumer-1| [thrd:main]: my-topic [0]: rd_kafka_toppar_op_fetch_stop:2357: new version barrier v4
%7|1633443244.880|CONSUMER|rdkafka#consumer-1| [thrd:main]: Stop consuming my-topic [0] (v4)
%7|1633443244.880|BARRIER|rdkafka#consumer-1| [thrd:main]: my-topic [0]: rd_kafka_toppar_op_pause_resume:2416: new version barrier v5
%7|1633443244.880|RESUME|rdkafka#consumer-1| [thrd:main]: Resume my-topic [0] (v5)
%7|1633443244.880|DESP|rdkafka#consumer-1| [thrd:main]: Removing (un)desired topic my-topic [0]
%7|1633443244.880|REMOVE|rdkafka#consumer-1| [thrd:main]: Removing my-topic [0] from assignment (started=true, pending=false, queried=false, stored offset=112389)
%7|1633443244.880|REMOVE|rdkafka#consumer-1| [thrd:main]: Served 1 removed partition(s), with 1 offset(s) to commit
%7|1633443244.880|COMMIT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Committing offsets for 1 partition(s): unassigned partitions
%7|1633443244.880|OFFSET|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Enqueue OffsetCommitRequest(v7, 1/1 partition(s))): unassigned partitions
%7|1633443244.880|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Current assignment of 0 partition(s) with 0 pending adds, 0 offset queries, 1 partitions awaiting stop and 1 offset commits in progress
%7|1633443244.880|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "my-app": waiting for 1 toppar(s), assignment in progress, 1 commit(s) (state up, join-state init) before terminating
%7|1633443244.880|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "my-app": waiting for 1 toppar(s), assignment in progress, 1 commit(s) (state up, join-state init) before terminating
%7|1633443244.880|OP|rdkafka#consumer-1| [thrd:main]: my-topic [0] received op FETCH_STOP (v4) in fetch-state active (opv3)
%7|1633443244.880|FETCH|rdkafka#consumer-1| [thrd:main]: Stopping fetch for my-topic [0] in state active (v4)
%7|1633443244.880|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition my-topic [0] changed fetch state active -> stopping
%7|1633443244.880|STORETERM|rdkafka#consumer-1| [thrd:main]: my-topic [0]: offset store terminating
%7|1633443244.880|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition my-topic [0] changed fetch state stopping -> stopped
%7|1633443244.880|SEND|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Sent OffsetCommitRequest (v7, 84 bytes @ 0, CorrId 2)
%7|1633443244.880|OP|rdkafka#consumer-1| [thrd:main]: my-topic [0] received op PAUSE (v5) in fetch-state stopped (opv4)
%7|1633443244.880|RESUME|rdkafka#consumer-1| [thrd:main]: Not resuming my-topic [0]: partition is not paused by library
%7|1633443244.880|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "my-app": waiting for 1 toppar(s), assignment in progress, 1 commit(s) (state up, join-state init) before terminating
%7|1633443244.880|CGRPOP|rdkafka#consumer-1| [thrd:main]: Group "my-app" received op PARTITION_LEAVE in state up (join-state init) for my-topic [0]
%7|1633443244.880|PARTDEL|rdkafka#consumer-1| [thrd:main]: Group "my-app": delete my-topic [0]
%7|1633443244.880|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "my-app": waiting for 0 toppar(s), assignment in progress, 1 commit(s) (state up, join-state init) before terminating
%7|1633443244.880|STOPSERVE|rdkafka#consumer-1| [thrd:main]: All partitions awaiting stop are now stopped: serving assignment
%7|1633443244.880|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
%7|1633443244.880|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1633443244.880|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1633443244.880|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1633443244.880|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1633443244.880|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Current assignment of 0 partition(s) with 0 pending adds, 0 offset queries, 0 partitions awaiting stop and 1 offset commits in progress
%7|1633443244.880|CGRPTERM|rdkafka#consumer-1| [thrd:main]: Group "my-app": waiting for 0 toppar(s), assignment in progress, 1 commit(s) (state up, join-state init) before terminating
%7|1633443244.883|RECV|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/0: Received OffsetCommitResponse (v7, 39 bytes, CorrId 2, rtt 2.31ms)
%7|1633443244.883|COMMIT|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: OffsetCommit for 1 partition(s) in join-state init: unassigned partitions: returned: Success
%7|1633443244.883|DUMP|rdkafka#consumer-1| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
%7|1633443244.883|DUMP_ALL|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1633443244.883|DUMP_PND|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1633443244.883|DUMP_QRY|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1633443244.883|DUMP_REM|rdkafka#consumer-1| [thrd:main]: List with 0 partition(s):
%7|1633443244.883|ASSIGNDONE|rdkafka#consumer-1| [thrd:main]: Group "my-app": assignment operations done in join-state init (rebalance rejoin=false)
%7|1633443244.883|CGRPSTATE|rdkafka#consumer-1| [thrd:main]: Group "my-app" changed state up -> term (join-state init)
%7|1633443244.883|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1633443244.883|ASSIGNMENT|rdkafka#consumer-1| [thrd:main]: Group "my-app": clearing group assignment
%7|1633443244.883|COORDCLEAR|rdkafka#consumer-1| [thrd:main]: Group "my-app" broker 172.200.0.224:9092/0 is no longer coordinator
%7|1633443244.883|NODENAME|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Broker nodename changed from "172.200.0.224:9092" to ""
%7|1633443244.883|NODEID|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/0: Broker nodeid changed from 0 to -1
%7|1633443244.883|CLOSE|rdkafka#consumer-1| [thrd:app]: Consumer closed
%7|1633443244.883|DESTROY|rdkafka#consumer-1| [thrd:app]: Terminating instance (destroy flags NoConsumerClose (0x8))
%7|1633443244.883|TERMINATE|rdkafka#consumer-1| [thrd:app]: Terminating consumer group handler
%7|1633443244.883|CLOSE|rdkafka#consumer-1| [thrd:app]: Closing consumer
%7|1633443244.883|CLOSE|rdkafka#consumer-1| [thrd:app]: Disabling and purging temporary queue to quench close events
%7|1633443244.883|CLOSE|rdkafka#consumer-1| [thrd:app]: Consumer closed
%7|1633443244.883|TERMINATE|rdkafka#consumer-1| [thrd:app]: Interrupting timers
%7|1633443244.883|TERMINATE|rdkafka#consumer-1| [thrd:app]: Sending TERMINATE to internal main thread
%7|1633443244.883|FAIL|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Closing connection due to nodename change (after 871ms in state UP) (_TRANSPORT)
%7|1633443244.883|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state UP -> DOWN
%7|1633443244.883|TERMINATE|rdkafka#consumer-1| [thrd:main]: Internal main thread terminating
%7|1633443244.883|DESTROY|rdkafka#consumer-1| [thrd:main]: Destroy internal
%7|1633443244.883|BROADCAST|rdkafka#consumer-1| [thrd:main]: Broadcasting state change
%7|1633443244.883|DESTROY|rdkafka#consumer-1| [thrd:main]: Removing all topics
%7|1633443244.883|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1633443244.883|TERMINATE|rdkafka#consumer-1| [thrd:app]: Joining internal main thread
%7|1633443244.883|PARTCNT|rdkafka#consumer-1| [thrd:main]: Topic my-topic partition count changed from 1 to 0
%7|1633443244.883|REMOVE|rdkafka#consumer-1| [thrd:main]: my-topic [0] no longer reported in metadata
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Purging bufq with 0 buffers
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Purging bufq with 0 buffers
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Updating 0 buffers on connection reset
%7|1633443244.883|BRKTERM|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: terminating: broker still has 3 refcnt(s), 0 buffer(s), 0 partition(s)
%7|1633443244.883|BRKMIGR|rdkafka#consumer-1| [thrd:main]: my-topic [0] 0x7fb9240016d0 sending final LEAVE for removal by 172.200.0.224:9092/0
%7|1633443244.883|METADATA|rdkafka#consumer-1| [thrd:GroupCoordinator]: Requesting metadata for 1/1 topics: broker down
%7|1633443244.883|TOPPARREMOVE|rdkafka#consumer-1| [thrd:main]: Removing toppar my-topic [-1] 0x7fb924001170
%7|1633443244.883|DESTROY|rdkafka#consumer-1| [thrd:main]: my-topic [-1]: 0x7fb924001170 DESTROY_FINAL
%7|1633443244.883|METADATA|rdkafka#consumer-1| [thrd:GroupCoordinator]: 172.200.0.224:9092/0: Request metadata for 1 topic(s): broker down
%7|1633443244.883|DESTROY|rdkafka#consumer-1| [thrd:main]: Sending TERMINATE to 172.200.0.224:9092/0
%7|1633443244.883|FETCH|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Topic my-topic [0] in state stopped at offset 112388 (0/100000 msgs, 0/65536 kb queued, opv 3) is not fetchable: forced removal
%7|1633443244.883|TERMINATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Handle is terminating in state DOWN: 3 refcnts (0x1a94530), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf
%7|1633443244.883|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state DOWN -> INIT
%7|1633443244.883|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1633443244.883|DESTROY|rdkafka#consumer-1| [thrd:main]: Sending TERMINATE to 172.200.0.250:9092/bootstrap
%7|1633443244.883|FETCHADD|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Removed my-topic [0] from fetch list (0 entries, opv 3): forced removal
%7|1633443244.883|DESTROY|rdkafka#consumer-1| [thrd:main]: Sending TERMINATE to GroupCoordinator
%7|1633443244.883|TOPBRK|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Topic my-topic [0]: leaving broker (0 messages in xmitq, next broker (none), rktp 0x7fb9240016d0)
%7|1633443244.883|TERMINATE|rdkafka#consumer-1| [thrd:main]: Purging reply queue
%7|1633443244.883|TERMINATE|rdkafka#consumer-1| [thrd:main]: Decommissioning internal broker
%7|1633443244.883|TOPBRK|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Topic my-topic [0]: no next broker, failing 0 message(s) in partition queue
%7|1633443244.883|BROADCAST|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: Broadcasting state change
%7|1633443244.883|TERM|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs
%7|1633443244.883|TERM|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Received TERMINATE op in state INIT: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs
%7|1633443244.883|TERM|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Received TERMINATE op in state UP: 2 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs
%7|1633443244.883|TERM|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Received TERMINATE op in state UP: 5 refcnts, 0 toppar(s), 0 active toppar(s), 1 outbufs, 1 waitresps, 0 retrybufs
%7|1633443244.883|TERMINATE|rdkafka#consumer-1| [thrd:main]: Join 4 broker thread(s)
%7|1633443244.883|FAIL|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Client is terminating (after 0ms in state INIT) (_DESTROY)
%7|1633443244.883|FAIL|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Client is terminating (after 1374ms in state INIT) (_DESTROY)
%7|1633443244.883|FAIL|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Client is terminating (after 873ms in state UP) (_DESTROY)
%7|1633443244.883|STATE|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Broker changed state UP -> DOWN
%7|1633443244.883|FAIL|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Client is terminating (after 373ms in state UP) (_DESTROY)
%7|1633443244.883|STATE|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Broker changed state UP -> DOWN
%7|1633443244.883|STATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state INIT -> DOWN
%7|1633443244.883|BROADCAST|rdkafka#consumer-1| [thrd:GroupCoordinator]: Broadcasting state change
%7|1633443244.883|STATE|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Broker changed state INIT -> DOWN
%7|1633443244.883|BROADCAST|rdkafka#consumer-1| [thrd::0/internal]: Broadcasting state change
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Purging bufq with 0 buffers
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Purging bufq with 0 buffers
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Updating 0 buffers on connection reset
%7|1633443244.883|BRKTERM|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s)
%7|1633443244.883|BROADCAST|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: Broadcasting state change
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Updating 0 buffers on connection reset
%7|1633443244.883|BRKTERM|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s)
%7|1633443244.883|TERMINATE|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Handle is terminating in state DOWN: 1 refcnts (0x1a94530), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf
%7|1633443244.883|TERMINATE|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Handle is terminating in state DOWN: 1 refcnts (0x1a95490), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf
%7|1633443244.883|FAIL|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY)
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: Updating 0 buffers on connection reset
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Purging bufq with 0 buffers
%7|1633443244.883|BROADCAST|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: Broadcasting state change
%7|1633443244.883|FAIL|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY)
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Purging bufq with 0 buffers
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Purging bufq with 0 buffers
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: Updating 0 buffers on connection reset
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Purging bufq with 1 buffers
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Purging bufq with 0 buffers
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Updating 0 buffers on connection reset
%7|1633443244.883|BRKTERM|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s)
%7|1633443244.883|TOPPARREMOVE|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: Removing toppar my-topic [0] 0x7fb9240016d0
%7|1633443244.883|DESTROY|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: my-topic [0]: 0x7fb9240016d0 DESTROY_FINAL
%7|1633443244.883|TERMINATE|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Handle is terminating in state DOWN: 1 refcnts (0x1a962d0), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Purging bufq with 1 buffers
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Updating 0 buffers on connection reset
%7|1633443244.883|BRKTERM|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: terminating: broker still has 2 refcnt(s), 0 buffer(s), 0 partition(s)
%7|1633443244.883|FAIL|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY)
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Purging bufq with 0 buffers
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Purging bufq with 0 buffers
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd:172.200.0.250:9092/bootstrap]: 172.200.0.250:9092/bootstrap: Updating 0 buffers on connection reset
%7|1633443244.883|TERMINATE|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Handle is terminating in state DOWN: 1 refcnts (0x7fb9240028a0), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf
%7|1633443244.883|FAIL|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY)
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Purging bufq with 0 buffers
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Purging bufq with 0 buffers
%7|1633443244.883|BUFQ|rdkafka#consumer-1| [thrd:172.200.0.224:9092/0]: 172.200.0.224:9092/0: Updating 0 buffers on connection reset
%7|1633443244.883|TERMINATE|rdkafka#consumer-1| [thrd:main]: Internal main thread termination done
%7|1633443244.883|TERMINATE|rdkafka#consumer-1| [thrd:app]: Destroying op queues
%7|1633443244.883|TERMINATE|rdkafka#consumer-1| [thrd:app]: Destroying cgrp
%7|1633443244.883|MEMBERID|rdkafka#consumer-1| [thrd:app]: Group "my-app": updating member id "" -> "(not-set)"
%7|1633443244.883|TERMINATE|rdkafka#consumer-1| [thrd:app]: Termination done: freeing resources
Checklist
Please provide the following information:
- [x] librdkafka version : 1.6.1
- [x] Apache Kafka version:
2.6.0 - [x] librdkafka client configuration:
default values - [x] Operating system:
Centos 8 - [x] Provide logs (with
debug=..as necessary) from librdkafka - [ ] Provide broker log excerpts
- [ ] Critical issue
hi librdkafka team,
we noticed that with java API the time to complete topic assignation process if at least twice as fast as to complete the assignation process in C++ with librdkafka.
We would like to know if there is a mean to reduce this duration of assignation with librdkafka. We would have thought that assignation is far quicker than subscription. At least we would have expected that librdkafka is at least quicker than java API. May have we missed something in librdkafka configuration?
thank you for your help guys :)
librdkafka v1.9.0 has some improvements in speedier broker thread wakeups which may help alleviate this situation.
Please try to reproduce on latest master and see if it is still an issue. Thanks