broker as tcp v4

main
Simon Aubury 2023-02-14 16:01:18 +11:00
rodzic f837b3dfb9
commit e5e18d5bd9
1 zmienionych plików z 2 dodań i 1 usunięć

Wyświetl plik

@ -14,7 +14,8 @@ def acked(err, msg):
def kafka_producer():
producer_config = {
'bootstrap.servers': 'localhost:9092',
'schema.registry.url': 'http://localhost:8081'
'schema.registry.url': 'http://localhost:8081',
'broker.address.family': 'v4'
}
value_schema = avro.load('avro/mastodon-topic-value.avsc')