Kafka pipeline for Twitter data to Elasticsearch