Mirror of Apache Kafka

kafkascala

You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

Tree: eb50d2f6ca

Branches Tags

${ item.name }

Create tag ${ searchTerm }

Create branch ${ searchTerm }

from 'eb50d2f6ca'

${ noResults }

src-kafka/tests/kafkatest/utils

History

Anna Povzner 4e0ae79d5c KAFKA-3214: Added system tests for compressed topics ... 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		9 years ago
..
__init__.py	KAFKA-3214: Added system tests for compressed topics	9 years ago
remote_account.py	KAFKA-2531: Add Ducktape based tests for KafkaLog4jAppender	9 years ago
util.py	KAFKA-3214: Added system tests for compressed topics	9 years ago