How Does Kafka Stream Twitter Data?
How Does Kafka Stream Twitter Data? Now we create the run() method which first calls createTwitterClient() method to connect to Twitter client and then createKafkaProducer() to create and get kafka producer instance. We use BlockingQueue<String> msgQueue to fetch the data from client and producer. send(new ProducerRecord<String, String>(KafkaConfig. How does Kafka get data from twitter? Now