diff --git a/bluesky_widgets/qt/kafka_dispatcher.py b/bluesky_widgets/qt/kafka_dispatcher.py
index 6a480b9..679f24a 100644
--- a/bluesky_widgets/qt/kafka_dispatcher.py
+++ b/bluesky_widgets/qt/kafka_dispatcher.py
@@ -92,7 +92,7 @@ def continue_polling_forever():
         while continue_polling():
             try:
                 # there should maybe be a poll method on the dispatcher
-                msg = self._dispatcher._bluesky_consumer.consumer.poll(
+                msg = self._dispatcher._bluesky_consumer._consumer.poll(
                     self._dispatcher._bluesky_consumer.polling_duration
                 )
                 if msg is None:
@@ -116,7 +116,7 @@ def continue_polling_forever():
                                 # doc.
                                 logger.debug("keep waiting for a start document")
                                 return
-                        yield self._dispatcher._bluesky_consumer.consumer, msg.topic(), name, document
+                        yield self._dispatcher._bluesky_consumer._consumer, msg.topic(), name, document
                     except Exception as exc:
                         logger.exception(exc)
             except Exception as exc: