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 ;