Kafka Twitter Producer Consume the Twitter Streaming API and send all messages to a Kafka broker. Use Twitter4j. Configuration Set up your Twitter API credentials and your Kafka brokers in conf/producer.conf Execution just run gradlew run -Pargs="PATH_TO/producer.conf"