This repositories was created to provide the way to send and get data to and from aws kinesis with go programming langange (golang). We will using kinesis-local docker image to get simulation of aws kinesis in local computer.
This project was devided to be three sub folder :
consumerto consume data from kinesisproducerto product data to kinesisstreamto create or delete streaming name
Build:
docker build -t kinesis-local .or you can use docker image in https://hub.docker.com/r/ruanbekker/kinesis-local
Run and expose port 4567:
docker run -it -p 4567:4567 kinesis-local:latest
Create or delete stream name :
- Move to
streamfolder to create or delete stream name go build stream.go- create :
./stream -action=create - delete :
./stream -action=delete
Produce and consume data (split the terminal to be 2 part, so you can see simulation of data stream):
- Move to producer folder to produce/send data to kinesis and
go run produce.go - Move to consumer folder to consume/get data from kinesis and
go run consume.go
GOOD LUCK :)