Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Fix broken RST docs #3062

Merged
merged 3 commits into from
Dec 5, 2024
Merged
Show file tree
Hide file tree
Changes from 2 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:
emdneto marked this conversation as resolved.
Show resolved Hide resolved
.. 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:
emdneto marked this conversation as resolved.
Show resolved Hide resolved
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:
emdneto marked this conversation as resolved.
Show resolved Hide resolved

.. code: python
.. code:: python

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

Expand Down
Loading