Machine Learning with Apache Spark Quick Start Guide

Kafka topic

Next, we need to create a Kafka topic to which our Python Kafka producer application (which we will develop later on) will publish real-time tweets about airlines. In our case, we will call the topic twitter. As demonstrated in Chapter 2, Setting Up a Local Development Environment, this can be achieved as follows:

> bin/kafka-topics.sh --create --zookeeper 192.168.56.10:2181 --replication-factor 1 --partitions 1 --topic twitter