app.start_client() never returns

[dparker18]

Steps to reproduce

import faust
import asyncio

app = faust.App('foo', broker = 'kafka://kafka-broker.internal:29092')), web_enabled = False)
topic = app.topic('foo', key_type = str, value_type = str)

async def test():
	print('before start_client...')
	await app.start_client()
	print('after start_client...')
	return await topic.send_soon(value = 'bar')

if __name__ == '__main__':
	loop1 = asyncio.get_event_loop()
	print(loop1.run_until_complete(test()))

Expected behavior

Client-only mode is initialized and data posted to the topic

Actual behavior

App hangs forever at app.start_client(). I believe I found the bug, PR coming shortly

Full traceback

no error, just blocks

Versions

• Python version: Python 3.8.10
• Faust version: 0.6.9
• Operating system: Ubuntu 20.04.3 LTS
• Kafka version: 6.2.0-ccs (Commit:1a5755cf9401c84f)
• RocksDB version (if applicable): n/a