When we stop a KafkaStream or Sub in a distributed setup, it is currently not possible to start them again as we lost all information about the nodes (they deregistered themselves from the cluster).
Therefore, we need to introduce a service-discovery mechanism to be able to restart our nodes.
When we stop a
KafkaStream
orSub
in a distributed setup, it is currently not possible to start them again as we lost all information about the nodes (they deregistered themselves from the cluster). Therefore, we need to introduce a service-discovery mechanism to be able to restart our nodes.