-
Notifications
You must be signed in to change notification settings - Fork 50
Open
Description
- Source can't connect to kafka\other resource - executor wait 10 sedonds ()
Line 264 in 223d445
time.Sleep(10 * time.Second) - During this period of time, a shutdown message is received by app ()
Line 271 in 223d445
func (e *Executor) Shutdown() (done chan struct{}) { - Executor try to shutdown source, but old instance ()
Line 274 in 223d445
err := e.source.Shutdown() - Executor continues to execute an infinite loop ()
Line 250 in 223d445
for { - New source instance doesn't know anything about studown signal
- Go to step 4
=>
App does not respond to system shutdown signals
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
No labels