Kafka - Event-Driven Architecture
Given this Kafka CQRS code snippet:
commands_topic = 'orders-commands'
queries_topic = 'orders-queries'
# Command handler writes event
producer.send(commands_topic, {'orderId': 1, 'action': 'create'})
# Query handler reads events
consumer.subscribe([queries_topic])
# What will the query handler receive?