Fix soaktest to run without TestConsumer

as new protocol configuration can be put in configuration
properties file

Author: emasab

tests/soak/soakclient.py

@@ -26,12 +26,11 @@
 #
 
 from confluent_kafka import KafkaError, KafkaException, version
-from confluent_kafka import Producer
+from confluent_kafka import Producer, Consumer
 from confluent_kafka.admin import AdminClient, NewTopic
 from collections import defaultdict
 from builtins import int
 from opentelemetry import metrics
-from common import TestConsumer
 import argparse
 import threading
 import time
@@ -447,7 +446,7 @@ def filter_config(conf, filter_out, strip_prefix):
         cconf['error_cb'] = self.consumer_error_cb
         cconf['on_commit'] = self.consumer_commit_cb
         self.logger.info("consumer: using group.id {}".format(cconf['group.id']))
-        self.consumer = TestConsumer(cconf)
+        self.consumer = Consumer(cconf)
 
         # Create and start producer thread
         self.producer_thread = threading.Thread(target=self.producer_thread_main)