sky-uk/kafka-topic-loader

Idle timeout is applied to post loading source

Closed this issue · 0 comments

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.