从ElasticSearch提取到Kafka

从ElasticSearch提取到Kafka