kafka-python icon indicating copy to clipboard operation
kafka-python copied to clipboard

Published 20 hours ago • verified publisher icon dpkp

How to verify compress type of the message in a topic?

Open wangchaoforever opened this issue 2 years ago • 1 comments

I have too many topics(maybe 2000). I want to verify compress type of all topic. I know kafka self's command kafka-dump-log.sh can show the compress type of message. But it must to login the kafka server and execute the command with the log file name. I think this way is too slow.Does kafka-python support it?

wangchaoforever avatar Jun 24 '22 06:06 wangchaoforever

I know pykafka has a consumer attributes named .compression_type. It can help me to verify the producer's compress type. Does kafka-python has a similar comsumer attributes?

wangchaoforever avatar Jun 28 '22 07:06 wangchaoforever