Borrowed heavily from Patrick Callaghan's datastax-kafka-example.
The goal of this version is to have a producer generate stock tick data and write to the tick-stream topic and then
have a consumer read from the topic and write the tick data to a Cassandra table.
First start Kafka and add the topic tick-stream following these basic instructions.
Download and start DSE.
Setup the Cassandra schema by running the SchemaSetup class.
Note: the keyspace replication settings use SimpleStrategy.
Modify as needed.
Start the TickProducer with the desired number of events.
Start the TickConsumer.
You can run the following in cqlsh:
select * from datastax_tickdata_demo.tick_data ;