Source connector should support listening for keyspace notifications to capture change data and publish them to a Kafka topic