reduce transaction log level of aiokafka transport (#107)

faust-streaming · Feb 18, 2021 · 0ef8771 · 0ef8771
1 parent 466dbf2
commit 0ef8771
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/faust/transport/drivers/aiokafka.py b/faust/transport/drivers/aiokafka.py
@@ -1113,7 +1113,7 @@ async def commit_transaction(self, transactional_id: str) -> None:
                 transaction_producer = self._transaction_producers.get(transactional_id)
                 if transaction_producer:
                     await transaction_producer.commit_transaction()
-                    logger.info(f"Done committing transaction {transactional_id}")
+                    logger.debug(f"Done committing transaction {transactional_id}")
                 else:
                     logger.warning(
                         f"Commit invoked for unknown transaction {transactional_id}"
@@ -1183,11 +1183,11 @@ async def commit_transactions(
                         offsets, group_id
                     )
                     await transaction_producer.commit_transaction()
-                    logger.info(f"Done committing transaction {transactional_id}")
+                    logger.debug(f"Done committing transaction {transactional_id}")
                     if start_new_transaction:
-                        logger.info(f"Starting transaction {transactional_id}")
+                        logger.debug(f"Starting transaction {transactional_id}")
                         await transaction_producer.begin_transaction()
-                        logger.info(f"Started transaction {transactional_id}")
+                        logger.debug(f"Started transaction {transactional_id}")
 
                 else:
                     logger.warning(