mirror of https://github.com/apache/kafka.git
4e0ae79d5c
Added CompressionTest that tests 4 producers, each using a different compression type and one not using compression. Enabled VerifiableProducer to run producers with different compression types (passed in the constructor). This includes enabling each producer to output unique values, so that the verification process in ProduceConsumeValidateTest is correct (counts acks from all producers). Also a fix for console consumer to raise an exception if it sees the incorrect consumer output (before we swallowed an exception, so was hard to debug the issue). Author: Anna Povzner <anna@confluent.io> Reviewers: Geoff Anderson, Jason Gustafson Closes #958 from apovzner/kafka-3214 |
||
|---|---|---|
| .. | ||
| __init__.py | ||
| remote_account.py | ||
| util.py | ||