Samuel Cantero

Use the kafkaadmin client to query the kafka state

1

In order to prepare kafka-kit for zk-less kafka, we need to implement at least the following methods from [zkhandler](https://pkg.go.dev/github.com/DataDog/kafka-kit/[email protected]/kafkazk#ZKHandler) into [kafkaadmin/client](https://pkg.go.dev/github.com/DataDog/kafka-kit/[email protected]/kafkaadmin#Client). This should query kafka directly rather than zk. *...

Indicate the pool name and specify number of brokers expected/actual as currently it only errors out with: `{"error":"insufficient number of brokers","code":2,"message":"insufficient number of brokers"} `

Error propagation differences between the callback and event API

2

Description =========== I'm trying to migrate [rust-rdkafka](https://github.com/fede1024/rust-rdkafka/pull/617) from the callback based API to the event one. If we consume messages via the callback API (i.e `rd_kafka_consumer_poll`), then RD_KAFKA_OP_ERR errors are...