confluent-kafka-python
confluent-kafka-python copied to clipboard
How to verify compress type of the message on consumer
Description
How to verify compress type of the message on consumer?
How to reproduce
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 confluent-kafka-python support it?
Checklist
Please provide the following information:
- [x] confluent-kafka-python and librdkafka version (
confluent_kafka.version(1.7.0)andconfluent_kafka.libversion(1.7.0)): - [x] Apache Kafka broker version: 2.7.0
- [ ] Client configuration:
{...} - [ ] Operating system:
- [ ] Provide client logs (with
'debug': '..'as necessary) - [ ] Provide broker log excerpts
- [ ] Critical issue