With StreamWorkManager, Kafka, and nuxeo.stream.work.storestate.enabled=true, the server logs intermittently include the following WorkComputation WARN message indicating that the StreamWorkManager consumer is dropping a Work:
This typically occurs when lots of Works are being scheduled concurrently. In this case, it appears a state synchronization issue exists between the MongoDB KeyValueStore and the Kafka StreamWorkManager. See:
Specifically, our suspicion is that WorkComputation line 96 is being invoked from one thread in between the time lines 155 and 160 are invoked in another thread thus causing the dropped Work.