Convert an Scala Kafka Producer/Consumer to use a Kafka Streams Postgres sink.
More information about Kafka Streams and Postgres sinks are here:
Https://[login to view URL]
[login to view URL]
[login to view URL]
Kafka Streams should be configured to have exactly once semantic.
There will be two milestones:
1) Completion of code and unit tests
2) Successful review and local integration on client's environment