Refactor Cassandra integration test.
Add C* producer integration test.