Consumes messages from Twitter using Twitter4j library and sends the tweets into Apache Kafka broker.
Configure you Twitter API credentials and Kafka broker in resources/application.yaml
. Default configuration
assumes that you have a topic named twitter present in your Kafka broker.
This project is built using Gradle. If you do not have gradle installed on your system, just run
gradlew build
. This command will in-place download Gradle and will build the project. Resulting jar
file will be located under build/libs
directory.
java -jar kafka-twitter-producer-0.0.1.jar
This code is not intended for production usage, it was written as a quick intro to Apache Kafka during ZOOM International Hackathon (Autumn 2017).