Hello, We want to process messages from a single KafkaStream in a number of processes. Is it possible to have this code executing in multiple threads against the same stream?
for (message <- stream) {
someBlockingOperation(message)
}
The scaladocs mention thread safety, but some of the code seems fairly
stateful. I was wondering if anyone has experience with this or knows if it
will work?
Thanks,
David
