We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7cb0b8c commit b7269dcCopy full SHA for b7269dc
arroyo/processing/processor.py
@@ -272,6 +272,7 @@ def _close_processing_strategy(self) -> None:
272
return
273
274
logger.info("Closing %r...", self.__processing_strategy)
275
+ logger.info("Member id: %r", self.__consumer.member_id)
276
self.__processing_strategy.close()
277
278
logger.info("Waiting for %r to exit...", self.__processing_strategy)
0 commit comments