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: