loosing data during saving data from java

[adrien ruffie]

Hello all,

I have a table cassandra where I insert quickly several java entity
about 15.000 entries by minutes. But at the process ending, I only
have for exemple 199.921 entries instead 312.212
If I truncate the table and relaunch the process, several time I get 199.354
or 189.012 entries ... not a really fixed entries saved any time ...

several coworker tell me, they heard about a buffer which can be overwhelmed
sometimes, and loosing several entities stacked for insertion ...
right ?
Because I don't understand why this loosing insertion appears ...
And I java code is very simple like below:

myEntitiesList.forEach(myEntity -> {
  try {
    myEntitiesRepository.save(myEntity).subscribe();
    } catch (Exception e) {
    e.printStackTrace();
    }
    }

And the repository is a:
public interface MyEntityRepository extends 
ReactiveCassandraRepository<MyEntity, String> {
}


Some one already heard about this problem ?

Thank you very must and best regards

Adrian