Analyzing streaming transactions with Zeppelin

At this point, if you have not done so yet, you should start the following processes on your machine. Please refer to the previous sections if you are not sure how to start them:

• Zookeeper
• Kafka broker
• The StreamingProducerApp consuming live BTC/USD transactions and pushing them to a Kafka topic named transactions.
• Apache Zeppelin

Reading transactions from Kafka

Using your browser, create a new Zeppelin Notebook named Streaming, and  then type the following code in the first cell:

case class Transaction(timestamp: java.sql.Timestamp,
                       date: String,
                       tid: Int,
                       price: Double,
                       sell: Boolean,
                       amount: Double)
val schema = Seq.empty[Transaction].toDS().schema

Execute the cell to define the Transaction class and the variable schema. We have to redefine the Transaction case class in Zeppelin because Zeppelin does not have access to the classes of...