redpanda_kafka_python_producer_quickstart_json_messages.py

1import json
2from kafka import KafkaProducer
3
4# Initialize the KafkaProducer
5# Replace 'localhost:9092' with your Redpanda broker address
6producer = KafkaProducer(
7    bootstrap_servers=['localhost:9092'],
8    value_serializer=lambda v: json.dumps(v).encode('utf-8')
9)
10
11# Define the topic to produce to
12topic = 'test-topic'
13
14# Create a sample message
15message = {'key': 'value', 'message': 'Hello, Redpanda!'}
16
17# Produce the message
18try:
19    future = producer.send(topic, value=message)
20    # Wait for the message to be sent
21    record_metadata = future.get(timeout=10)
22    print(f"Message sent to topic {record_metadata.topic} at offset {record_metadata.offset}")
23except Exception as e:
24    print(f"Error producing message: {e}")
25finally:
26    # Close the producer
27    producer.close()