diff options
| author | Dana Powers <dana.powers@gmail.com> | 2015-06-08 16:07:57 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2015-06-08 16:07:57 -0700 |
| commit | 062ddffa1ddc5499ecf9781ce75ea20c8ec9289d (patch) | |
| tree | d36bd4fee1368919a25870cce77f12f97990c08e /test | |
| parent | ce702ef22182906f379293b0ca2c2be47fc4c077 (diff) | |
| parent | 45c263037cba15e120a103a9e21753c1c7a277b2 (diff) | |
| download | kafka-python-062ddffa1ddc5499ecf9781ce75ea20c8ec9289d.tar.gz | |
Merge pull request #379 from dpkp/deprecate_keyed_producer_send
Deprecate KeyedProducer.send in favor of send_messages
Diffstat (limited to 'test')
| -rw-r--r-- | test/test_producer_integration.py | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/test/test_producer_integration.py b/test/test_producer_integration.py index 3c414e1..3439f4e 100644 --- a/test/test_producer_integration.py +++ b/test/test_producer_integration.py @@ -346,10 +346,10 @@ class TestKafkaProducerIntegration(KafkaIntegrationTestCase): start_offsets = [self.current_offset(self.topic, p) for p in partitions] producer = KeyedProducer(self.client, partitioner=RoundRobinPartitioner) - resp1 = producer.send(self.topic, self.key("key1"), self.msg("one")) - resp2 = producer.send(self.topic, self.key("key2"), self.msg("two")) - resp3 = producer.send(self.topic, self.key("key3"), self.msg("three")) - resp4 = producer.send(self.topic, self.key("key4"), self.msg("four")) + resp1 = producer.send_messages(self.topic, self.key("key1"), self.msg("one")) + resp2 = producer.send_messages(self.topic, self.key("key2"), self.msg("two")) + resp3 = producer.send_messages(self.topic, self.key("key3"), self.msg("three")) + resp4 = producer.send_messages(self.topic, self.key("key4"), self.msg("four")) self.assert_produce_response(resp1, start_offsets[0]+0) self.assert_produce_response(resp2, start_offsets[1]+0) @@ -367,11 +367,11 @@ class TestKafkaProducerIntegration(KafkaIntegrationTestCase): start_offsets = [self.current_offset(self.topic, p) for p in partitions] producer = KeyedProducer(self.client, partitioner=HashedPartitioner) - resp1 = producer.send(self.topic, self.key("1"), self.msg("one")) - resp2 = producer.send(self.topic, self.key("2"), self.msg("two")) - resp3 = producer.send(self.topic, self.key("3"), self.msg("three")) - resp4 = producer.send(self.topic, self.key("3"), self.msg("four")) - resp5 = producer.send(self.topic, self.key("4"), self.msg("five")) + resp1 = producer.send_messages(self.topic, self.key("1"), self.msg("one")) + resp2 = producer.send_messages(self.topic, self.key("2"), self.msg("two")) + resp3 = producer.send_messages(self.topic, self.key("3"), self.msg("three")) + resp4 = producer.send_messages(self.topic, self.key("3"), self.msg("four")) + resp5 = producer.send_messages(self.topic, self.key("4"), self.msg("five")) offsets = {partitions[0]: start_offsets[0], partitions[1]: start_offsets[1]} messages = {partitions[0]: [], partitions[1]: []} @@ -400,7 +400,7 @@ class TestKafkaProducerIntegration(KafkaIntegrationTestCase): producer = KeyedProducer(self.client, partitioner = RoundRobinPartitioner, async=True) - resp = producer.send(self.topic, self.key("key1"), self.msg("one")) + resp = producer.send_messages(self.topic, self.key("key1"), self.msg("one")) self.assertEqual(len(resp), 0) # wait for the server to report a new highwatermark |