We should have a system test coverage for the Kafka Connector auto-restart.

I added a simple option to fail a task to my echo-sink connector. So maybe we can use it. If needed, we can add more or write a separate connector.