genreate

Author: ItayGibel-helios

instrumentation/opentelemetry-instrumentation-kafka-python/src/opentelemetry/instrumentation/kafka/__init__.py

@@ -78,10 +78,7 @@ def consume_hook(span, record, args, kwargs):
 from opentelemetry import trace
 from opentelemetry.instrumentation.instrumentor import BaseInstrumentor
 from opentelemetry.instrumentation.kafka.package import _instruments
-from opentelemetry.instrumentation.kafka.utils import (
-    _wrap_next,
-    _wrap_send,
-)
+from opentelemetry.instrumentation.kafka.utils import _wrap_next, _wrap_send
 from opentelemetry.instrumentation.kafka.version import __version__
 from opentelemetry.instrumentation.utils import unwrap
 

instrumentation/opentelemetry-instrumentation-kafka-python/src/opentelemetry/instrumentation/kafka/utils.py

@@ -1,6 +1,7 @@
 import json
 from logging import getLogger
 from typing import Callable, Dict, List, Optional
+
 from kafka.record.abc import ABCRecord
 
 from opentelemetry import context, propagate, trace