Fix broken RST docs

Author: buger

docs/instrumentation/aiokafka/aiokafka.rst

@@ -1,8 +1,65 @@
 .. include:: ../../../instrumentation/opentelemetry-instrumentation-aiokafka/README.rst
     :end-before: References
 
+Usage
+=====
+
+The instrumentation will track producer and consumer operations.
+
+Producer Example
+----------------
+
+.. code-block:: python
+
+    import asyncio
+    from opentelemetry.instrumentation.aiokafka import AioKafkaInstrumentor
+    from aiokafka import AIOKafkaProducer
+
+    async def produce():
+        # Enable instrumentation
+        AioKafkaInstrumentor().instrument()
+
+        # Use aiokafka producer as usual
+        producer = AIOKafkaProducer(bootstrap_servers=['localhost:9092'])
+        await producer.start()
+        try:
+            await producer.send_and_wait('my-topic', b'raw_bytes')
+        finally:
+            await producer.stop()
+
+    asyncio.run(produce())
+
+Consumer Example
+----------------
+
+.. code-block:: python
+
+    import asyncio
+    from opentelemetry.instrumentation.aiokafka import AioKafkaInstrumentor
+    from aiokafka import AIOKafkaConsumer
+
+    async def consume():
+        # Enable instrumentation
+        AioKafkaInstrumentor().instrument()
+
+        # Use aiokafka consumer as usual
+        consumer = AIOKafkaConsumer(
+            'my-topic',
+            bootstrap_servers=['localhost:9092'],
+            group_id='my-group',
+            auto_offset_reset='earliest'
+        )
+        await consumer.start()
+        try:
+            async for msg in consumer:
+                print(f'Received message: {msg.value.decode("utf-8")}')
+        finally:
+            await consumer.stop()
+
+    asyncio.run(consume())
+
 API
----
+===
 
 .. automodule:: opentelemetry.instrumentation.aiokafka
     :members:

docs/instrumentation/confluent_kafka/confluent_kafka.rst

@@ -1,4 +1,71 @@
 .. include:: ../../../instrumentation/opentelemetry-instrumentation-confluent-kafka/README.rst
+    :end-before: References
+
+Usage
+=====
+
+The instrumentation will track producer and consumer operations.
+
+Producer Example
+----------------
+
+.. code-block:: python
+
+    from opentelemetry.instrumentation.confluent_kafka import ConfluentKafkaInstrumentor
+    from confluent_kafka import Producer
+
+    # Enable instrumentation
+    ConfluentKafkaInstrumentor().instrument()
+
+    # Use confluent-kafka producer as usual
+    conf = {'bootstrap.servers': 'localhost:9092'}
+    producer = Producer(conf)
+    producer.produce('my-topic', value=b'raw_bytes')
+    producer.flush()
+
+Consumer Example
+----------------
+
+.. code-block:: python
+
+    from confluent_kafka import Consumer, KafkaError, KafkaException
+    from opentelemetry.instrumentation.confluent_kafka import ConfluentKafkaInstrumentor
+    import sys
+
+    # Enable instrumentation
+    ConfluentKafkaInstrumentor().instrument()
+
+    # Use confluent-kafka consumer as usual
+    conf = {
+        'bootstrap.servers': 'localhost:9092',
+        'group.id': 'foo',
+        'auto.offset.reset': 'smallest'
+    }
+    consumer = Consumer(conf)
+
+    def basic_consume_loop(consumer, topics):
+        try:
+            consumer.subscribe(topics)
+            while True:
+                msg = consumer.poll(timeout=1.0)
+                if msg is None:
+                    continue
+                if msg.error():
+                    if msg.error().code() == KafkaError._PARTITION_EOF:
+                        # End of partition event
+                        sys.stderr.write(f'{msg.topic()} [{msg.partition()}] reached end at offset {msg.offset()}')
+                    else:
+                        raise KafkaException(msg.error())
+                else:
+                    # Process the message here
+                    print(f'Received message: {msg.value().decode("utf-8")}')
+        finally:
+            consumer.close()
+
+    basic_consume_loop(consumer, ['my-topic'])
+
+API
+===
 
 .. automodule:: opentelemetry.instrumentation.confluent_kafka
     :members:

docs/instrumentation/kafka_python/kafka_python.rst

@@ -1,10 +1,54 @@
 .. include:: ../../../instrumentation/opentelemetry-instrumentation-kafka-python/README.rst
     :end-before: References
 
+Usage
+=====
+
+The instrumentation will track producer and consumer operations.
+
+Producer Example
+----------------
+
+.. code-block:: python
+
+    from opentelemetry.instrumentation.kafka import KafkaInstrumentor
+    from kafka import KafkaProducer
+
+    # Enable instrumentation
+    KafkaInstrumentor().instrument()
+
+    # Use kafka-python producer as usual
+    producer = KafkaProducer(bootstrap_servers=['localhost:9092'])
+    producer.send('my-topic', b'raw_bytes')
+    producer.flush()
+
+Consumer Example
+----------------
+
+.. code-block:: python
+
+    from opentelemetry.instrumentation.kafka import KafkaInstrumentor
+    from kafka import KafkaConsumer
+
+    # Enable instrumentation
+    KafkaInstrumentor().instrument()
+
+    # Use kafka-python consumer as usual
+    consumer = KafkaConsumer(
+        'my-topic',
+        bootstrap_servers=['localhost:9092'],
+        group_id='my-group',
+        auto_offset_reset='earliest'
+    )
+
+    # Process messages
+    for message in consumer:
+        print(f'Received message: {message.value.decode("utf-8")}')
+
 API
----
+===
 
-.. automodule:: opentelemetry.instrumentation.kafka
+.. automodule:: opentelemetry.instrumentation.kafka_python
     :members:
     :undoc-members:
     :show-inheritance: