Great job on the article and the project here 🚀

I see that here is missing .env_example or .env specifically. I think it supposed to be on /geostream directory.

Best,

Thanks for putting together this example. I encountered an issue when building the app . The env_file is not available in the geostream folder which caused the docker compose to fail. So I removed it.

env_file:
- ./geostream/.env

When checking geo-stream-kafka_producer docker I saw the following error . Hope you can help .

File "./app/main.py", line 5, in <module>
    from app.core.config import KAFKA_INSTANCE
  File "./app/core/config.py", line 12, in <module>
    KAFKA_URI: str = config("KAFKA_URI")
  File "/usr/local/lib/python3.7/site-packages/starlette/config.py", line 62, in __call__
    return self.get(key, cast, default)
  File "/usr/local/lib/python3.7/site-packages/starlette/config.py", line 75, in get
    raise KeyError(f"Config '{key}' is missing, and has no default.")
KeyError: "Config 'KAFKA_URI' is missing, and has no default."

After running the services through docker ubuntu, I configured the variables for kafka as you wrote localhost:9092.
My kafka is accessible from the client, I can connect to it via the client gui. But the service doesn't connect to it, I always get the same error.
kafka.errors.KafkaConnectionError: KafkaConnectionError: Unable to bootstrap from [('localhost', 9092, <AddressFamily.AF_UNSPEC: 0>)]

Please help, what could be the problem, have you encountered it?

producer_1 | File "/usr/local/lib/python3.7/site-packages/starlette/routing.py", line 566, in aenter
producer_1 | await self._router.startup()
producer_1 | file "/usr/local/lib/python3.7/site-packages/starlette/routing.py", line 648, in startup
producer_1 | await handler()
producer_1 | file "./app/main.py", line 22, in startup_event
producer_1 | await aioproducer.start()
producer_1 | file "/usr/local/lib/python3.7/site-packages/aiokafka/producer/producer.py", line 307, in start
producer_1 | await self.client.bootstrap()
producer_1 | file "/usr/local/lib/python3.7/site-packages/aiokafka/client.py", line 252, in bootstrap
producer_1 | f'Unable to bootstrap from {self.hosts}')
producer_1 | kafka.errors.KafkaConnectionError: KafkaConnectionError: Unable to bootstrap from [('localhost', 9092, <AddressFamily.AF_UNSPEC: 0>)]