I consume data from Kafka and insert them into Cassandra cluster using Java API. The table has 4 keys including a timestamp based on millisecond. But when executing the code, it just inserts 120 to 190 rows and ignores other incoming data!
What parts can be the cause of the problem? Bad insert code in key fields that overwrite data, improper cluster configuration,....?
