search

sudoblockio / icon-governance-v1

0 stars 0 forks source link

Kafka/Protobuf backwards compatibility flag #21

Closed shinyfoil closed 2 years ago

shinyfoil commented 2 years ago

Worker is now complaining about needing a backward compatibility flag.

Traceback (most recent call last):
  File "/opt/icon_governance/main_worker.py", line 74, in <module>
    main(args.worker_type)
  File "/opt/icon_governance/main_worker.py", line 29, in main
    transactions_worker_head()
  File "/opt/icon_governance/workers/transactions.py", line 152, in transactions_worker_head
    kafka = TransactionsWorker(
  File "/opt/icon_governance/workers/kafka.py", line 87, in __init__
    self.consumer_deserializer = ProtobufDeserializer(TransactionRaw)
  File "/usr/local/lib/python3.9/site-packages/confluent_kafka/schema_registry/protobuf.py", line 471, in __init__
    raise RuntimeError(
RuntimeError: ProtobufDeserializer: the 'use.deprecated.format' configuration property must be explicitly set due to backward incompatibility with older confluent-kafka-python Protobuf producers and consumers. See the release notes for more details