Remove maybe_wait_for_producer_id test debug statements; PID => producer_id

Author: dpkp

Diff for: kafka/producer/sender.py

@@ -134,7 +134,7 @@ def run_once(self):
         for expired_batch in expired_batches:
             self._sensors.record_errors(expired_batch.topic_partition.topic, expired_batch.record_count)
 
-        # Reset the PID if an expired batch has previously been sent to the broker.
+        # Reset the producer_id if an expired batch has previously been sent to the broker.
         # See the documentation of `TransactionState.reset_producer_id` to understand why
         # we need to reset the producer id here.
         if self._transaction_state and any([batch.in_retry() for batch in expired_batches]):
@@ -195,9 +195,7 @@ def add_topic(self, topic):
             self.wakeup()
 
     def _maybe_wait_for_producer_id(self):
-        log.debug("_maybe_wait_for_producer_id")
         if not self._transaction_state:
-            log.debug("_maybe_wait_for_producer_id: no transaction_state...")
             return
 
         while not self._transaction_state.has_pid():
@@ -230,7 +228,6 @@ def _maybe_wait_for_producer_id(self):
             except Errors.RequestTimedOutError:
                 log.debug("InitProducerId request to node %s timed out", node_id)
             time.sleep(self.config['retry_backoff_ms'] / 1000)
-        log.debug("_maybe_wait_for_producer_id: ok: %s", self._transaction_state.producer_id_and_epoch)
 
     def _failed_produce(self, batches, node_id, error):
         log.error("Error sending produce request to node %d: %s", node_id, error) # trace