Skip to content

Commit

Permalink
Update readme
Browse files Browse the repository at this point in the history
  • Loading branch information
kaplanbora committed May 19, 2020
1 parent 83a558b commit 5ca5cf8
Showing 1 changed file with 28 additions and 1 deletion.
29 changes: 28 additions & 1 deletion README.md
Original file line number Diff line number Diff line change
@@ -1 +1,28 @@
# Transaction Consumer
# Expense Stream
This is an example to demonstrate how Akka Stream coexists with Akka Typed. You can read the full article [here](https://kaplan.dev/articles/akka-stream-coexistence-with-akka-typed/).

### How to Run
Create a local kafka cluster and required topics
```bash
cd kafka-docker
docker-compose up -d
```

Start kafka console consumer to read the results
```bash
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic transactions-destination
```

Run the application
```bash
sbt run
```

Copy example payload and send it with producer
```bash
xclip -selection clipboard payload.json
kafka-console-producer.sh --broker-list localhost:9092 --topic transactions-source
> { "id": "1234", "amount": 13.37, "description": "Test", "timestamp": 1589133043 }
>
```

0 comments on commit 5ca5cf8

Please sign in to comment.