[kafka] improve verbosity while rebalancing consumers (#1166)

tensorflow · Oct 31, 2020 · d258989 · d258989
1 parent 4782435
commit d258989
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/tensorflow_io/core/kernels/kafka_kernels.cc b/tensorflow_io/core/kernels/kafka_kernels.cc
@@ -786,8 +786,8 @@ class KafkaRebalanceCb : public RdKafka::RebalanceCb {
 
       LOG(INFO) << "REBALANCE: " << partitions[partition]->topic() << "["
                 << partitions[partition]->partition() << "], "
-                << partitions[partition]->offset() << " "
-                << partitions[partition]->err();
+                << "OFFSET: " << partitions[partition]->offset() << " "
+                << "ERROR_CODE: " << partitions[partition]->err();
     }
     if (err == RdKafka::ERR__ASSIGN_PARTITIONS) {
       // librdkafka does not actually look up the stored offsets before