Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@
Usage
-----

..code:: python
.. code:: python

from opentelemetry.instrumentation.aiokafka import AIOKafkaInstrumentor
from aiokafka import AIOKafkaProducer, AIOKafkaConsumer
Expand All @@ -45,7 +45,8 @@ def async_produce_hook(span: Span, args, kwargs)
def async_consume_hook(span: Span, record: kafka.record.ABCRecord, args, kwargs)
for example:

.. code: python
.. code:: python

from opentelemetry.instrumentation.kafka import AIOKafkaInstrumentor
from aiokafka import AIOKafkaProducer, AIOKafkaConsumer

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@
Usage
-----

.. code-block:: python
.. code:: python

from opentelemetry.instrumentation.confluent_kafka import ConfluentKafkaInstrumentor
from confluent_kafka import Producer, Consumer
Expand Down Expand Up @@ -54,7 +54,6 @@ def basic_consume_loop(consumer, topics):
consumer.close()

basic_consume_loop(consumer, "my-topic")
---

The _instrument method accepts the following keyword args:
tracer_provider (TracerProvider) - an optional tracer provider
Expand Down Expand Up @@ -95,7 +94,6 @@ def instrument_consumer(consumer: Consumer, tracer_provider=None)
p.produce('my-topic',b'raw_bytes')
msg = c.poll()

___
"""

from typing import Collection
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@
Usage
-----

..code:: python
.. code:: python

from opentelemetry.instrumentation.kafka import KafkaInstrumentor
from kafka import KafkaProducer, KafkaConsumer
Expand All @@ -45,7 +45,8 @@ def produce_hook(span: Span, args, kwargs)
def consume_hook(span: Span, record: kafka.record.ABCRecord, args, kwargs)
for example:

.. code: python
.. code:: python

from opentelemetry.instrumentation.kafka import KafkaInstrumentor
from kafka import KafkaProducer, KafkaConsumer

Expand Down
Loading