example producer with no schema

prod_test_avro_no-schema.py

from confluent_kafka import avro
from confluent_kafka.avro import AvroProducer

# load schema to the registry from one producer
value_schema = avro.load('test_schema.avsc')

# This producer creates the schema and registers it
p1 = AvroProducer({
    'bootstrap.servers': 'localhost:9092',
    'schema.registry.url': 'http://localhost:8081'
    },
    default_value_schema=value_schema
)

# This producer doesn't know about the schema
p2 = AvroProducer({
    'bootstrap.servers': 'localhost:9092',
    'schema.registry.url': 'http://localhost:8081'
    }
)

topic = 'test.avro'

for i in range(100):
    p1.produce(topic=topic, value={"f1": "value" + str(i)})

# I need to get the schema_id, which is not easily exposed
schema_id = p1._serializer.registry_client.get_latest_schema(topic+'-value')[0]

for i in range(100):
    p2.produce(
        topic=topic,
        value={"f1": "value" + str(i)},
        value_schema_id=schema_id
    )

p1.flush()
p2.flush()