Idle timeout is applied to post loading source
Closed this issue · 0 comments
lacarvalho91 commented
In here we are adding a kafkaSource
which has an idle timeout.
This would mean that the run
source after topic loading will error with a timeout if there are no new messages. We should remove idleTimeout
from kafkaSource
and add it here in the only place it should be used.