Class KafkaConnector