Geo Stream Kafka Save Abandoned

producer and consumer FastAPI endpoints to handle incoming geo data

Project README

geo-stream-kafka

setup geostream fastapi aiokafka

geostream gif

see blogpost for a more detailed description

docker-compose up -d

If you're on MacOS set an environment variable like:

export DOCKER_KAFKA_HOST=$(ipconfig getifaddr en0)

that is afterwards used in docker-compose.yml to identify the KAFKA_ADVERTISED_HOST_NAME. Some similar workaround has to exist for Windows users. For linux I assume you can just set it to localhost if you're only running on Kafka node. See github.com/wurstmeister/kafka-docker/wiki/Connectivity.

Kafka

Kafka will be served on localhost:9092

Frontend

open /geostream/frontend/app/index.html and associated map.js will consume messages when they come in

Producer

can produce messages to a topic at localhost:8002/producer/<topicname>

Consumer

can consume kafka messages through at localhost:8003/consumer/<topicname>

Open Source Agenda is not affiliated with "Geo Stream Kafka" Project. README Source: iwpnd/geo-stream-kafka
Stars
62
Open Issues
1
Last Commit
4 years ago
License
MIT

Open Source Agenda Badge

Open Source Agenda Rating