Initial import for Kafka plugin.