GitHub

json_schema_consumer.py

parser.add_argument("--kafka-properties-file", type=str, required=True, help="Kafka client properties file") parser.add_argument("--sr-properties-file", type=str ...
GitHub

json_schema_producer.py

from confluent_kafka.schema_registry import SchemaRegistryClient, header_schema_id_serializer from confluent_kafka.schema_registry.json_schema import JSONSerializer ...