Consume messages from Kafka topics and load them into a destination.
bootstrap_servers, group_id, topics · supports incremental loads