Magnus Edenhill

You can sort of do this today by specifying an invalid topic: ``` $ ./kafkacat -b $BROKERS -L -t "" Metadata for (from broker -1: 0.0.0.0:57242/bootstrap): 3 brokers: broker 2...

I like this idea, question is what it should when the payload is not proper json, and thus might mess up the output: 1. output as-is, this is the easy...

Interesting ideas. I do believe this requires at least one or two actual use-cases as a proof-of-concept that it will work in practice.

I think the easiest approach here is to pass a path to a file which contains the token, and setting that token explicitly with set_token() upon kafkacat startup with a...

I've added experimental support to specify the token by file, please try it out on the [oauth](https://github.com/edenhill/kafkacat/tree/oauth) branch. `$ kafkacat -b mybrokers -L -X security.protocol=SASL_PLAINTEXT -X oauthbearer.token.file=YourFile -X oauthbearer.token.lifetime=12345 -X...

Is it possible that your topic is empty? I.e., the older messages have been deleted due to retention policies.

try enabling debugging to see what is going on: `kafkacat -L -b kafka-1:19092 -d broker`

What is your version of kafkacat and librdkafka? `kafkacat -V` nit: It'd be good if you could paste the output as text (within backtick quotes for formatting) rather than screenshots.

That looks really old. Upgrade both librdkafka and kafkacat. Easiest way is to remove kafkacat from your system, then download the kafkacat source code and follow the bootstrap instructions: https://github.com/edenhill/kafkacat#quick-build

https://github.com/edenhill/kafkacat/archive/1.4.0.tar.gz