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,....?

Reply via email to