robinhood / faust

Python Stream Processing

Other

6.73k stars 535 forks source link

Faust Error: Address In Used #777

Open johnnyb1509 opened 1 year ago

johnnyb1509 commented 1 year ago

Hi all,

I'm new user of Faust and don't know how to fix the problem when I ran 3 faust apps in the same time. Specifically:

I have 3 python file, In each, I run 1 service for listening from kafka server. Each file contains code as below, the different in each file is just the TOPIC_INPUT name.

app = faust.App(
    'UserInfoReceive',
    broker= 'kafka://' + SERVER_INPUT + f':{DVWAP_KAFKA_PORT}',
    value_serializer='raw',
)

kafka_topic = app.topic(TOPIC_INPUT)

@app.agent(kafka_topic)
async def userSettingInput(streamInput):
    async for msg in streamInput:
        userResgister(msg)

Expected behavior

Expect 3 python files can run normally and listen to the comming kafka event

Actual behavior

it generates OSError as this img

Versions

Python version: 3.9
Faust version 1.10.4
Operating system WSL Linux Subsystem on Windows
Kafka version kafka-python==1.4.7