I’m working in a projects where in we are writing a system to re-engineer the search of a hotel chain platform.
The use cases are like such wherein changes in entities saved in Couchbase are sent to kafka topic which are processed by Spark Stream processing. The changes can be like a room is booked, rate changes in room for a given hotel of a hotel chain. Currently all events for a hotel are being pushed to one partition of kafka.
In my view we should be using Akka stream where in the change events are being processed by the Actors instead of only using stream processing only.
Can someone please clarify ?