Give kafka its own worker and add its stop

gwcelery/data/gwcelery.sub

@@ -26,6 +26,10 @@ arguments = "gwcelery worker -l info -n gwcelery-worker@%h -f %n.log -Q celery -
 description = gwcelery-worker
 queue
 
+arguments = "gwcelery worker -l info -n gwcelery-kafka-worker@%h -f %n.log -Q kafka --kafka -c 1 --prefetch-multiplier 1"
+description = gwcelery-kafka-worker
+queue
+
 arguments = "gwcelery worker -l info -n gwcelery-exttrig-worker@%h -f %n.log -Q exttrig -c 1"
 description = gwcelery-exttrig-worker
 queue

gwcelery/kafka/bootsteps.py

@@ -27,6 +27,7 @@ class KafkaBootStep(bootsteps.ConsumerStep):
         log.info(f'Starting {self.name}, topic: {self.topic_url}')
 
     def stop(self, parent):
+        super().stop(parent)
         log.info(f'Closing connection to topic: {self.topic_url}')