diff --git a/opl/skip_to_end.py b/opl/skip_to_end.py
index d732ea3..3842d53 100755
--- a/opl/skip_to_end.py
+++ b/opl/skip_to_end.py
@@ -23,7 +23,6 @@ def doit_seek_to_end(kafka_hosts, kafka_timeout, kafka_topic, kafka_group, args=
 
     # Common parameters for both cases
     common_params = {
-        topics: kafka_topic,
         bootstrap_servers: kafka_hosts,
         auto_offset_reset: "latest",
         enable_auto_commit: True,
@@ -51,6 +50,8 @@ def doit_seek_to_end(kafka_hosts, kafka_timeout, kafka_topic, kafka_group, args=
         )
         consumer = KafkaConsumer(**common_params)
 
+    consumer.subscribe(kafka_topic)
+
     # Seek to end
     for attempt in range(10):
         try: