POC-Kafka .Net Core

Architecture

Workflow

• Product API expose Delete Product Endpoint, when called, the kafka producer send message on delete-product topic to notify consumer.
• Recipe API consumer read the message and delete all recipes with the deleted product.
• Both Consumer group are here to show that a message is read one and only one time by consumer group
• Product and Recipe Get Endpoints are here to check data base state after deletion.
• A five seconds sleep are here to show the asynchronous principle of Kafka.

Other Sources

• https://github.com/confluentinc/confluent-kafka-dotnet
• https://hub.docker.com/r/confluentinc/cp-kafka/
• https://hub.docker.com/r/confluentinc/cp-zookeeper