search

robinhood / faust

Python Stream Processing
Other
6.74k stars 533 forks source link

faust can not run with kafka 0.10.2.1 #553

Open JianFeiWang opened 4 years ago

JianFeiWang commented 4 years ago

faust.exceptions.ProducerSendError: Error while sending: UnsupportedVersionError('Headers not supported before Kafka 0.11')

JianFeiWang commented 4 years ago

this error happend when i run the Quick Start demo

ftconan commented 2 years ago

You can specify the kafka version when init app(producer_api_version).

app = faust.App(
    'hello-world',
    broker='kafka://localhost:9092',
    producer_api_version='0.10.2',
)