diff options
| author |   DR695H <dr695h@att.com> | 2019-08-28 10:52:51 -0400 |
|---|---|---|
| committer | DR695H <dr695h@att.com> | 2019-08-28 11:21:56 -0400 |
| commit | f2b75da8dd38077c60cc2c852f73092980c1f906 (patch) | |
| tree | f58fc4de4f54eec45e10717fabcb62d7cbe64182 /robotframework-onap/ONAPLibrary/KafkaKeywords.py | |
| parent | 566c583bbfe0b5a4e46af7ac53765a1340d11fc0 (diff) | |
fix linter errors and copyright
Change-Id: Idf7384307623c70a9f7714a5d276f404873c5974
Issue-ID: TEST-198
Signed-off-by: DR695H <dr695h@att.com>
Diffstat (limited to 'robotframework-onap/ONAPLibrary/KafkaKeywords.py')
| -rw-r--r-- | robotframework-onap/ONAPLibrary/KafkaKeywords.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/robotframework-onap/ONAPLibrary/KafkaKeywords.py b/robotframework-onap/ONAPLibrary/KafkaKeywords.py index 6cdf85f..44ffb49 100644 --- a/robotframework-onap/ONAPLibrary/KafkaKeywords.py +++ b/robotframework-onap/ONAPLibrary/KafkaKeywords.py @@ -96,14 +96,14 @@ class KafkaKeywords(object): partitions = [] for val in partition_set: partitions.append(TopicPartition(str(topic_name), val)) - consumer.assign(partitions) - last = consumer.end_offsets(partitions) - offset = max(last.values()) + consumer.assign(partitions) + last = consumer.end_offsets(partitions) + offset = max(last.values()) if set_offset_to_earliest: consumer.seek_to_beginning() else: for tp in partitions: - consumer.seek(tp, offset - 1) + consumer.seek(tp, offset - 1) return consumer |