Create a web service using your preferred programming language and framework (e.g., Python with Flask).
Implement two endpoints:
/orders
(POST): Accepts JSON payload representing a product order and publishes it to the Kafka topic "product_orders"./orders
(GET): Retrieves all product orders from the PostgreSQL database and returns them as JSON.
Implement a DB sink connector which reads "product_orders" topic and writes the data to a table called orders
in Postgres DB.
Write a Kafka consumer which consumes from "product_orders" and writes to a respective city topic. For ex, in the below order payload: