Currently, users have to consume heartbeat messages themselves manually.

Using KSql, custom code or the console script:

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic __mongodb_heartbeats --skip-message-on-error

This is not very user friendly and we should provide a way to do this easily.

Perhaps a background thread in the Source could handle it or a custom Sink handler.