Skip to content

Commit fcf8c50

Browse files
change documentation
1 parent a0f6eea commit fcf8c50

File tree

1 file changed

+1
-2
lines changed
  • instrumentation/opentelemetry-instrumentation-confluent-kafka/src/opentelemetry/instrumentation/confluent_kafka

1 file changed

+1
-2
lines changed

instrumentation/opentelemetry-instrumentation-confluent-kafka/src/opentelemetry/instrumentation/confluent_kafka/__init__.py

+1-2
Original file line numberDiff line numberDiff line change
@@ -47,8 +47,7 @@ def basic_consume_loop(consumer, topics):
4747
if msg.error():
4848
if msg.error().code() == KafkaError._PARTITION_EOF:
4949
# End of partition event
50-
sys.stderr.write('%% %s [%d] reached end at offset %d\n' %
51-
(msg.topic(), msg.partition(), msg.offset()))
50+
sys.stderr.write(f"{msg.topic()} [{msg.partition()}] reached end at offset {msg.offset()}}\n")
5251
elif msg.error():
5352
raise KafkaException(msg.error())
5453
else:

0 commit comments

Comments
 (0)