Faust Error: Address In Used

[johnnyb1509]

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