mirror of
https://github.com/open-telemetry/opentelemetry-python-contrib.git
synced 2025-07-29 21:23:55 +08:00
Fix usage docs for confluent_kafka (#1400)
This commit is contained in:
@ -20,7 +20,7 @@ Usage
|
|||||||
|
|
||||||
..code:: python
|
..code:: python
|
||||||
|
|
||||||
from opentelemetry.instrumentation.confluentkafka import ConfluentKafkaInstrumentor
|
from opentelemetry.instrumentation.confluent_kafka import ConfluentKafkaInstrumentor
|
||||||
from confluent_kafka import Producer, Consumer
|
from confluent_kafka import Producer, Consumer
|
||||||
|
|
||||||
# Instrument kafka
|
# Instrument kafka
|
||||||
@ -69,7 +69,7 @@ instrument_consumer (Callable) - a function with extra user-defined logic to be
|
|||||||
def instrument_consumer(consumer: Consumer, tracer_provider=None)
|
def instrument_consumer(consumer: Consumer, tracer_provider=None)
|
||||||
for example:
|
for example:
|
||||||
.. code: python
|
.. code: python
|
||||||
from opentelemetry.instrumentation.confluentkafka import ConfluentKafkaInstrumentor
|
from opentelemetry.instrumentation.confluent_kafka import ConfluentKafkaInstrumentor
|
||||||
from confluent_kafka import Producer, Consumer
|
from confluent_kafka import Producer, Consumer
|
||||||
|
|
||||||
inst = ConfluentKafkaInstrumentor()
|
inst = ConfluentKafkaInstrumentor()
|
||||||
|
Reference in New Issue
Block a user