tchekai704/src-kafka - src-kafka - Gitea

Author	SHA1	Message	Date
Ewen Cheslack-Postava	59cfa84801	KAFKA-4037: Make Connect REST API retries aware of 409 CONFLICT errors Author: Ewen Cheslack-Postava <me@ewencp.org> Reviewers: Jason Gustafson <jason@confluent.io>, Ismael Juma <ismael@juma.me.uk> Closes #1733 from ewencp/rest-api-retries	8 years ago
Geoff Anderson	801fee89d8	MINOR: cleanup apache license in python files ijuma As discussed in https://github.com/apache/kafka/pull/1645, this patch removes an extraneous line from several __init__.py files, and a few others as well Author: Geoff Anderson <geoff@confluent.io> Reviewers: Ismael Juma <ismael@juma.me.uk> Closes #1659 from granders/minor-cleanup-init-files	8 years ago
Liquan Pei	dbafc631ad	KAFKA-3673: Connect tests don't handle concurrent config changes Author: Liquan Pei <liquanpei@gmail.com> Reviewers: Ewen Cheslack-Postava <ewen@confluent.io> Closes #1340 from Ishiihara/connect-test-failure	9 years ago
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
Rajini Sivaram	98db5ea94f	KAFKA-2644; Run relevant ducktape tests with SASL_PLAINTEXT and SASL_SSL Run sanity check, replication tests and benchmarks with SASL/Kerberos using MiniKdc. Author: Rajini Sivaram <rajinisivaram@googlemail.com> Reviewers: Geoff Anderson <geoff@confluent.io>, Jun Rao <junrao@gmail.com> Closes #358 from rajinisivaram/KAFKA-2644	9 years ago
Geoff Anderson	e6b343302f	KAFKA-1888: rolling upgrade test ewencp gwenshap This needs some refactoring to avoid the duplicated code between replication test and upgrade test, but in shape for initial feedback. I'm interested in feedback on the added `KafkaConfig` class and `kafka_props` file. This addition makes it: - easier to attach different configs to different nodes (e.g. during broker upgrade process) - easier to reason about the configuration of a particular node Notes: - in the default values in the KafkaConfig class, I removed many properties which were in kafka.properties before. This is because most of those properties were set to what is already the default value. - when running non-trunk VerifiableProducer, I append the trunk tools jar to the classpath, and run it with the non-trunk kafka-run-class.sh script Author: Geoff Anderson <geoff@confluent.io> Reviewers: Dong Lin, Ewen Cheslack-Postava Closes #229 from granders/KAFKA-1888-upgrade-test	9 years ago
Rajini Sivaram	dd514b2bb8	KAFKA-2581: Run some existing ducktape tests with SSL Parametrize console consumer sanity test, replication tests and benchmarks tests to run with both PLAINTEXT and SSL. Author: Rajini Sivaram <rajinisivaram@googlemail.com> Reviewers: Geoff Anderson, Ewen Cheslack-Postava, Guozhang Wang Closes #271 from rajinisivaram/KAFKA-2581	9 years ago
Ashish Singh	b62f8ea43b	KAFKA-2531: Add Ducktape based tests for KafkaLog4jAppender Author: Ashish Singh <asingh@cloudera.com> Reviewers: Geoff Anderson, Edwerd Ribeiro, Ewen Cheslack-Postava, Gwen Shapira Closes #235 from SinghAsDev/KAFKA-2531	9 years ago