You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jo...@apache.org on 2023/11/03 23:30:25 UTC
(kafka) branch kafka-15764 created (now 30e4f15439b)
This is an automated email from the ASF dual-hosted git repository.
jolshan pushed a change to branch kafka-15764
in repository https://gitbox.apache.org/repos/asf/kafka.git
at 30e4f15439b fix
This branch includes the following new commits:
new 7e0c0f4da4e Add compression to transactions test
new 30e4f15439b fix
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(kafka) 01/02: Add compression to transactions test
Posted by jo...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jolshan pushed a commit to branch kafka-15764
in repository https://gitbox.apache.org/repos/asf/kafka.git
commit 7e0c0f4da4e27c3e621e4c4c8e330d46d741525b
Author: Justine <jo...@confluent.io>
AuthorDate: Fri Nov 3 15:59:05 2023 -0700
Add compression to transactions test
---
tests/kafkatest/tests/core/transactions_test.py | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
diff --git a/tests/kafkatest/tests/core/transactions_test.py b/tests/kafkatest/tests/core/transactions_test.py
index 51ee971ef8f..a0602c2e9db 100644
--- a/tests/kafkatest/tests/core/transactions_test.py
+++ b/tests/kafkatest/tests/core/transactions_test.py
@@ -69,13 +69,14 @@ class TransactionsTest(Test):
if self.zk:
self.zk.start()
- def seed_messages(self, topic, num_seed_messages):
+ def seed_messages(self, topic, num_seed_messages, compression_types):
seed_timeout_sec = 10000
seed_producer = VerifiableProducer(context=self.test_context,
num_nodes=1,
kafka=self.kafka,
topic=topic,
message_validator=is_int,
+ compression_types=compression_types
max_messages=num_seed_messages,
enable_idempotence=True)
seed_producer.start()
@@ -246,8 +247,9 @@ class TransactionsTest(Test):
@matrix(failure_mode=["hard_bounce", "clean_bounce"],
bounce_target=["brokers", "clients"],
check_order=[True, False],
- use_group_metadata=[True, False])
- def test_transactions(self, failure_mode, bounce_target, check_order, use_group_metadata, metadata_quorum=quorum.all):
+ use_group_metadata=[True, False],
+ compression_types=["none", "snappy", "lz4", "gzip", "zstd"])
+ def test_transactions(self, failure_mode, bounce_target, check_order, use_group_metadata, compression_types, metadata_quorum=quorum.all):
security_protocol = 'PLAINTEXT'
self.kafka.security_protocol = security_protocol
self.kafka.interbroker_security_protocol = security_protocol
(kafka) 02/02: fix
Posted by jo...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jolshan pushed a commit to branch kafka-15764
in repository https://gitbox.apache.org/repos/asf/kafka.git
commit 30e4f15439b398c60c960a352a2b5870916d068f
Author: Justine <jo...@confluent.io>
AuthorDate: Fri Nov 3 16:30:06 2023 -0700
fix
---
tests/kafkatest/tests/core/transactions_test.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/tests/kafkatest/tests/core/transactions_test.py b/tests/kafkatest/tests/core/transactions_test.py
index a0602c2e9db..adf0cb3b50a 100644
--- a/tests/kafkatest/tests/core/transactions_test.py
+++ b/tests/kafkatest/tests/core/transactions_test.py
@@ -269,7 +269,7 @@ class TransactionsTest(Test):
self.setup_topics()
self.kafka.start()
- input_messages = self.seed_messages(self.input_topic, self.num_seed_messages)
+ input_messages = self.seed_messages(self.input_topic, self.num_seed_messages, compression_types)
concurrently_consumed_messages = self.copy_messages_transactionally(
failure_mode, bounce_target, input_topic=self.input_topic,
output_topic=self.output_topic, num_copiers=self.num_input_partitions,