Standard Output 2020-09-11 23:08:47,232 [Nuxeo-Consumer-01-0-rebalance-revoked] INFO [ConsumerPool] Creating consumer pool using Log assignments on logName: [[logName-00], [logName-01], [logName-02], [logName-03], [logName-04], [logName-05], [logName-06], [logName-07], [logName-08], [logName-09]] 2020-09-11 23:08:47,233 [Nuxeo-ProducerPool-00] WARN [AbstractCallablePool] Start Nuxeo-Producer Pool on 15 thread(s). 2020-09-11 23:08:47,234 [Nuxeo-ConsumerPool-00] WARN [AbstractCallablePool] Start Nuxeo-Consumer Pool on 10 thread(s). 2020-09-11 23:08:47,239 [Nuxeo-ProducerPool-00] INFO [AbstractCallablePool] Pool is up and running 2020-09-11 23:08:47,252 [Nuxeo-Producer-05-0-Random message 0] WARN [Slf4jExceptionHandler$2] Took 4 ms to add mapping for target-postgresql/junit5097951718192540867/junit12060547623164568658/logName/P-07/20200911.cq4 2020-09-11 23:08:47,253 [Nuxeo-Producer-07-0-Random message 0] WARN [Slf4jExceptionHandler$2] Took 2 ms to add mapping for target-postgresql/junit5097951718192540867/junit12060547623164568658/logName/P-05/20200911.cq4 2020-09-11 23:08:47,256 [Nuxeo-ConsumerPool-00] WARN [Slf4jExceptionHandler$2] Took 3 ms to add mapping for target-postgresql/junit5097951718192540867/junit12060547623164568658/logName/offset-default/metadata.cq4t 2020-09-11 23:08:47,266 [Nuxeo-ConsumerPool-00] WARN [Slf4jExceptionHandler$2] Took 3 ms to add mapping for target-postgresql/junit5097951718192540867/junit12060547623164568658/logName/offset-default/metadata.cq4t 2020-09-11 23:08:47,267 [Nuxeo-Producer-10-18-Random message 18] WARN [Slf4jExceptionHandler$2] Couldn't acquire write lock after 15000ms for the lock file:target-postgresql/junit5097951718192540867/junit12060547623164568658/logName/P-06/metadata.cq4t, overriding the lock. Lock was held by me 2020-09-11 23:08:47,267 [Nuxeo-Producer-07-3-Random message 3] WARN [Slf4jExceptionHandler$2] Couldn't acquire write lock after 15000ms for the lock file:target-postgresql/junit5097951718192540867/junit12060547623164568658/logName/P-06/metadata.cq4t, overriding the lock. Lock was held by me 2020-09-11 23:08:47,311 [Nuxeo-Producer-08-5-Random message 5] WARN [Slf4jExceptionHandler$2] Write lock was unlocked by someone else! For the lock file:target-postgresql/junit5097951718192540867/junit12060547623164568658/logName/P-06/metadata.cq4t 2020-09-11 23:08:47,269 [Nuxeo-Producer-10-18-Random message 18] WARN [Slf4jExceptionHandler$2] Forced unlock for the lock file:target-postgresql/junit5097951718192540867/junit12060547623164568658/logName/P-06/metadata.cq4t, unlocked: true net.openhft.chronicle.core.StackTrace: Forced unlock on Nuxeo-Producer-10-18-Random message 18 at net.openhft.chronicle.queue.impl.table.AbstractTSQueueLock.forceUnlock(AbstractTSQueueLock.java:52) ~[chronicle-queue-5.20.20.jar:?] at net.openhft.chronicle.queue.impl.single.TableStoreWriteLock.lock(TableStoreWriteLock.java:71) ~[chronicle-queue-5.20.20.jar:?] at net.openhft.chronicle.queue.impl.single.SingleChronicleQueue.cleanupStoreFilesWithNoData(SingleChronicleQueue.java:780) ~[chronicle-queue-5.20.20.jar:?] at net.openhft.chronicle.queue.impl.single.StoreAppender.(StoreAppender.java:66) ~[chronicle-queue-5.20.20.jar:?] at net.openhft.chronicle.queue.impl.single.SingleChronicleQueue.newAppender(SingleChronicleQueue.java:394) ~[chronicle-queue-5.20.20.jar:?] at net.openhft.chronicle.queue.impl.single.SingleChronicleQueue.createExcerptAppender(SingleChronicleQueue.java:426) ~[chronicle-queue-5.20.20.jar:?] at net.openhft.chronicle.queue.impl.single.SingleChronicleQueue.acquireAppender(SingleChronicleQueue.java:420) ~[chronicle-queue-5.20.20.jar:?] at org.nuxeo.lib.stream.log.chronicle.ChronicleLogAppender.append(ChronicleLogAppender.java:279) ~[nuxeo-stream-11.3.36.jar:?] at org.nuxeo.lib.stream.pattern.producer.internals.ProducerRunner.producerLoop(ProducerRunner.java:94) ~[classes/:?] at org.nuxeo.lib.stream.pattern.producer.internals.ProducerRunner.call(ProducerRunner.java:79) ~[classes/:?] at org.nuxeo.lib.stream.pattern.producer.internals.ProducerRunner.call(ProducerRunner.java:44) ~[classes/:?] at org.nuxeo.lib.stream.pattern.consumer.internals.AbstractCallablePool.lambda$runPool$1(AbstractCallablePool.java:99) ~[classes/:?] at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1700) [?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?] at java.lang.Thread.run(Thread.java:834) [?:?] 2020-09-11 23:08:47,425 [Nuxeo-Producer-07-3-Random message 3] WARN [Slf4jExceptionHandler$2] Forced unlock for the lock file:target-postgresql/junit5097951718192540867/junit12060547623164568658/logName/P-06/metadata.cq4t, unlocked: true net.openhft.chronicle.core.StackTrace: Forced unlock on Nuxeo-Producer-07-3-Random message 3 at net.openhft.chronicle.queue.impl.table.AbstractTSQueueLock.forceUnlock(AbstractTSQueueLock.java:52) ~[chronicle-queue-5.20.20.jar:?] at net.openhft.chronicle.queue.impl.single.TableStoreWriteLock.lock(TableStoreWriteLock.java:71) ~[chronicle-queue-5.20.20.jar:?] at net.openhft.chronicle.queue.impl.single.SingleChronicleQueue.cleanupStoreFilesWithNoData(SingleChronicleQueue.java:780) ~[chronicle-queue-5.20.20.jar:?] at net.openhft.chronicle.queue.impl.single.StoreAppender.(StoreAppender.java:66) ~[chronicle-queue-5.20.20.jar:?] at net.openhft.chronicle.queue.impl.single.SingleChronicleQueue.newAppender(SingleChronicleQueue.java:394) ~[chronicle-queue-5.20.20.jar:?] at net.openhft.chronicle.queue.impl.single.SingleChronicleQueue.createExcerptAppender(SingleChronicleQueue.java:426) ~[chronicle-queue-5.20.20.jar:?] at net.openhft.chronicle.queue.impl.single.SingleChronicleQueue.acquireAppender(SingleChronicleQueue.java:420) ~[chronicle-queue-5.20.20.jar:?] at org.nuxeo.lib.stream.log.chronicle.ChronicleLogAppender.append(ChronicleLogAppender.java:279) ~[nuxeo-stream-11.3.36.jar:?] at org.nuxeo.lib.stream.pattern.producer.internals.ProducerRunner.producerLoop(ProducerRunner.java:94) ~[classes/:?] at org.nuxeo.lib.stream.pattern.producer.internals.ProducerRunner.call(ProducerRunner.java:79) ~[classes/:?] at org.nuxeo.lib.stream.pattern.producer.internals.ProducerRunner.call(ProducerRunner.java:44) ~[classes/:?] at org.nuxeo.lib.stream.pattern.consumer.internals.AbstractCallablePool.lambda$runPool$1(AbstractCallablePool.java:99) ~[classes/:?] at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1700) [?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?] at java.lang.Thread.run(Thread.java:834) [?:?] 2020-09-11 23:08:47,426 [Nuxeo-Producer-05-2-Random message 2] ERROR [AbstractCallablePool] Exception catch in runner: Data was written after the end of the message, zero out data before rewinding [pos: 131655, rlim: 131655, wlim: 1180156, cap: 140737488355328 ] uxeo.lib.stream.pattern.KeyValueMessage\u0082⒛٠٠٠ðRandom message 2°°٠ǁ‡٠K٠٠٠Ãmsg¶,org.nuxeo.lib.stream.pattern.KeyValueMessage\u0082⒛٠٠٠ðRan java.lang.IllegalStateException: Data was written after the end of the message, zero out data before rewinding [pos: 131655, rlim: 131655, wlim: 1180156, cap: 140737488355328 ] uxeo.lib.stream.pattern.KeyValueMessage\u0082⒛٠٠٠ðRandom message 2°°٠ǁ‡٠K٠٠٠Ãmsg¶,org.nuxeo.lib.stream.pattern.KeyValueMessage\u0082⒛٠٠٠ðRan at net.openhft.chronicle.wire.AbstractWire.checkNoDataAfterEnd(AbstractWire.java:380) ~[chronicle-wire-2.20.22.jar:?] at net.openhft.chronicle.wire.AbstractWire.updateHeaderAssertions(AbstractWire.java:356) ~[chronicle-wire-2.20.22.jar:?] at net.openhft.chronicle.wire.AbstractWire.updateHeader(AbstractWire.java:347) ~[chronicle-wire-2.20.22.jar:?] at net.openhft.chronicle.queue.impl.single.StoreAppender$StoreAppenderContext.close(StoreAppender.java:758) ~[chronicle-queue-5.20.20.jar:?] at net.openhft.chronicle.queue.impl.single.StoreAppender$StoreAppenderContext.close(StoreAppender.java:738) ~[chronicle-queue-5.20.20.jar:?] at net.openhft.chronicle.wire.MarshallableOut.writeDocument(MarshallableOut.java:117) ~[chronicle-wire-2.20.22.jar:?] at org.nuxeo.lib.stream.log.chronicle.ChronicleLogAppender.append(ChronicleLogAppender.java:283) ~[nuxeo-stream-11.3.36.jar:?] at org.nuxeo.lib.stream.pattern.producer.internals.ProducerRunner.producerLoop(ProducerRunner.java:94) ~[classes/:?] at org.nuxeo.lib.stream.pattern.producer.internals.ProducerRunner.call(ProducerRunner.java:79) ~[classes/:?] at org.nuxeo.lib.stream.pattern.producer.internals.ProducerRunner.call(ProducerRunner.java:44) ~[classes/:?] at org.nuxeo.lib.stream.pattern.consumer.internals.AbstractCallablePool.lambda$runPool$1(AbstractCallablePool.java:99) ~[classes/:?] at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1700) [?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?] at java.lang.Thread.run(Thread.java:834) [?:?] 2020-09-11 23:08:47,512 [Nuxeo-Producer-11-10-Random message 10] WARN [Slf4jExceptionHandler$2] Write lock was unlocked by someone else! For the lock file:target-postgresql/junit5097951718192540867/junit12060547623164568658/logName/P-06/metadata.cq4t 2020-09-11 23:08:47,512 [Nuxeo-ConsumerPool-00] INFO [ChronicleLogOffsetTracker] Invalid offset tailer state: /home/jenkins/workspace/nuxeo_nuxeo_master/modules/platform/nuxeo-platform-importer/nuxeo-importer-stream/target-postgresql/junit5097951718192540867/junit12060547623164568658/logName/offset-default: BEYOND_START_OF_CYCLE taken as uninitialized 2020-09-11 23:08:47,512 [Nuxeo-Producer-10-35-Random message 35] ERROR [AbstractCallablePool] Exception catch in runner: Data was written after the end of the message, zero out data before rewinding [pos: 132856, rlim: 132856, wlim: 1181356, cap: 140737488355328 ] xeo.lib.stream.pattern.KeyValueMessage\u0082\u0015٠٠٠ñRandom message 16°°٠ǁ‡L٠٠٠Ãmsg¶,org.nuxeo.lib.stream.pattern.KeyValueMessage\u0082\u0015٠٠٠ñRand java.lang.IllegalStateException: Data was written after the end of the message, zero out data before rewinding [pos: 132856, rlim: 132856, wlim: 1181356, cap: 140737488355328 ] xeo.lib.stream.pattern.KeyValueMessage\u0082\u0015٠٠٠ñRandom message 16°°٠ǁ‡L٠٠٠Ãmsg¶,org.nuxeo.lib.stream.pattern.KeyValueMessage\u0082\u0015٠٠٠ñRand at net.openhft.chronicle.wire.AbstractWire.checkNoDataAfterEnd(AbstractWire.java:380) ~[chronicle-wire-2.20.22.jar:?] at net.openhft.chronicle.wire.AbstractWire.updateHeaderAssertions(AbstractWire.java:356) ~[chronicle-wire-2.20.22.jar:?] at net.openhft.chronicle.wire.AbstractWire.updateHeader(AbstractWire.java:347) ~[chronicle-wire-2.20.22.jar:?] at net.openhft.chronicle.queue.impl.single.StoreAppender$StoreAppenderContext.close(StoreAppender.java:758) ~[chronicle-queue-5.20.20.jar:?] at net.openhft.chronicle.queue.impl.single.StoreAppender$StoreAppenderContext.close(StoreAppender.java:738) ~[chronicle-queue-5.20.20.jar:?] at net.openhft.chronicle.wire.MarshallableOut.writeDocument(MarshallableOut.java:117) ~[chronicle-wire-2.20.22.jar:?] at org.nuxeo.lib.stream.log.chronicle.ChronicleLogAppender.append(ChronicleLogAppender.java:283) ~[nuxeo-stream-11.3.36.jar:?] at org.nuxeo.lib.stream.pattern.producer.internals.ProducerRunner.producerLoop(ProducerRunner.java:94) ~[classes/:?] at org.nuxeo.lib.stream.pattern.producer.internals.ProducerRunner.call(ProducerRunner.java:79) ~[classes/:?] at org.nuxeo.lib.stream.pattern.producer.internals.ProducerRunner.call(ProducerRunner.java:44) ~[classes/:?] at org.nuxeo.lib.stream.pattern.consumer.internals.AbstractCallablePool.lambda$runPool$1(AbstractCallablePool.java:99) ~[classes/:?] at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1700) [?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?] at java.lang.Thread.run(Thread.java:834) [?:?] 2020-09-11 23:08:47,519 [Nuxeo-Consumer-04-9-Random message 2] WARN [Slf4jExceptionHandler$2] Took 4 ms to add mapping for target-postgresql/junit5097951718192540867/junit12060547623164568658/logName/offset-default/20200911.cq4 2020-09-11 23:08:47,533 [Nuxeo-ConsumerPool-00] WARN [Slf4jExceptionHandler$2] Took 13 ms to add mapping for target-postgresql/junit5097951718192540867/junit12060547623164568658/logName/offset-default/20200911.cq4 2020-09-11 23:08:47,737 [Nuxeo-ConsumerPool-00] INFO [AbstractCallablePool] Pool is up and running 2020-09-11 23:08:47,915 [Nuxeo-Consumer-09-9-Random message 6] WARN [Slf4jExceptionHandler$2] Took 6 ms to add mapping for target-postgresql/junit5097951718192540867/junit12060547623164568658/logName/offset-default/20200911.cq4 2020-09-11 23:08:48,221 [Nuxeo-ProducerPool-00] ERROR [AbstractCallablePool] End of consumer in error: java.lang.IllegalStateException: Data was written after the end of the message, zero out data before rewinding [pos: 131655, rlim: 131655, wlim: 1180156, cap: 140737488355328 ] uxeo.lib.stream.pattern.KeyValueMessage\u0082⒛٠٠٠ðRandom message 2°°٠ǁ‡٠K٠٠٠Ãmsg¶,org.nuxeo.lib.stream.pattern.KeyValueMessage\u0082⒛٠٠٠ðRanjava.util.concurrent.CompletableFuture@12d03db8[Completed exceptionally: java.lang.IllegalStateException: Data was written after the end of the message, zero out data before rewinding [pos: 131655, rlim: 131655, wlim: 1180156, cap: 140737488355328 ] uxeo.lib.stream.pattern.KeyValueMessage\u0082⒛٠٠٠ðRandom message 2°°٠ǁ‡٠K٠٠٠Ãmsg¶,org.nuxeo.lib.stream.pattern.KeyValueMessage\u0082⒛٠٠٠ðRan] 2020-09-11 23:08:48,225 [Nuxeo-ProducerPool-00] ERROR [AbstractCallablePool] End of consumer in error: java.lang.IllegalStateException: Data was written after the end of the message, zero out data before rewinding [pos: 132856, rlim: 132856, wlim: 1181356, cap: 140737488355328 ] xeo.lib.stream.pattern.KeyValueMessage\u0082\u0015٠٠٠ñRandom message 16°°٠ǁ‡L٠٠٠Ãmsg¶,org.nuxeo.lib.stream.pattern.KeyValueMessage\u0082\u0015٠٠٠ñRandjava.util.concurrent.CompletableFuture@163a9da9[Completed exceptionally: java.lang.IllegalStateException: Data was written after the end of the message, zero out data before rewinding [pos: 132856, rlim: 132856, wlim: 1181356, cap: 140737488355328 ] xeo.lib.stream.pattern.KeyValueMessage\u0082\u0015٠٠٠ñRandom message 16°°٠ǁ‡L٠٠٠Ãmsg¶,org.nuxeo.lib.stream.pattern.KeyValueMessage\u0082\u0015٠٠٠ñRand] 2020-09-11 23:08:48,226 [Nuxeo-ProducerPool-00] INFO [ArrayList] Producer 00 status: messages: 1000, elapsed: 0.99s, throughput: 1015.23 msg/s. 2020-09-11 23:08:48,227 [Nuxeo-ProducerPool-00] INFO [ArrayList] Producer 01 status: messages: 1000, elapsed: 0.99s, throughput: 1015.23 msg/s. 2020-09-11 23:08:48,227 [Nuxeo-ProducerPool-00] INFO [ArrayList] Producer 02 status: messages: 1000, elapsed: 0.98s, throughput: 1018.33 msg/s. 2020-09-11 23:08:48,227 [Nuxeo-ProducerPool-00] INFO [ArrayList] Producer 03 status: messages: 1000, elapsed: 0.98s, throughput: 1024.59 msg/s. 2020-09-11 23:08:48,228 [Nuxeo-ProducerPool-00] INFO [ArrayList] Producer 04 status: messages: 1000, elapsed: 0.98s, throughput: 1022.49 msg/s. 2020-09-11 23:08:48,228 [Nuxeo-ProducerPool-00] INFO [ArrayList] Producer status FAILURE 2020-09-11 23:08:48,228 [Nuxeo-ProducerPool-00] INFO [ArrayList] Producer 06 status: messages: 1000, elapsed: 0.98s, throughput: 1020.41 msg/s. 2020-09-11 23:08:48,228 [Nuxeo-ProducerPool-00] INFO [ArrayList] Producer 07 status: messages: 1000, elapsed: 0.98s, throughput: 1025.64 msg/s. 2020-09-11 23:08:48,228 [Nuxeo-ProducerPool-00] INFO [ArrayList] Producer 08 status: messages: 1000, elapsed: 0.99s, throughput: 1014.20 msg/s. 2020-09-11 23:08:48,229 [Nuxeo-ProducerPool-00] INFO [ArrayList] Producer 09 status: messages: 1000, elapsed: 0.98s, throughput: 1018.33 msg/s. 2020-09-11 23:08:48,229 [Nuxeo-ProducerPool-00] INFO [ArrayList] Producer status FAILURE 2020-09-11 23:08:48,229 [Nuxeo-ProducerPool-00] INFO [ArrayList] Producer 11 status: messages: 1000, elapsed: 0.95s, throughput: 1049.32 msg/s. 2020-09-11 23:08:48,229 [Nuxeo-ProducerPool-00] INFO [ArrayList] Producer 12 status: messages: 1000, elapsed: 0.98s, throughput: 1022.49 msg/s. 2020-09-11 23:08:48,229 [Nuxeo-ProducerPool-00] INFO [ArrayList] Producer 13 status: messages: 1000, elapsed: 0.98s, throughput: 1023.54 msg/s. 2020-09-11 23:08:48,230 [Nuxeo-ProducerPool-00] INFO [ArrayList] Producer 14 status: messages: 1000, elapsed: 0.96s, throughput: 1040.58 msg/s. 2020-09-11 23:08:48,230 [Nuxeo-ProducerPool-00] WARN [ProducerPool] Producers status: threads: 15, failures: 2, messages: 13000, elapsed: 1599865728.23s, throughput: 0.00 msg/s 2020-09-11 23:08:53,241 [Nuxeo-Consumer-04-1316-Random message 994] INFO [ConsumerRunner] No record after: 5s on ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-04, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e}, terminating 2020-09-11 23:08:53,241 [Nuxeo-Consumer-04-1316-Random message 994] INFO [ConsumerRunner] No more message on tailer: ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-04, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e} 2020-09-11 23:08:53,242 [Nuxeo-Consumer-09-1379-Random message 996] INFO [ConsumerRunner] No record after: 5s on ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-09, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e}, terminating 2020-09-11 23:08:53,242 [Nuxeo-Consumer-05-1227-Random message 997] INFO [ConsumerRunner] No record after: 5s on ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-05, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e}, terminating 2020-09-11 23:08:53,244 [Nuxeo-Consumer-09-1379-Random message 996] INFO [ConsumerRunner] No more message on tailer: ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-09, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e} 2020-09-11 23:08:53,244 [Nuxeo-Consumer-05-1227-Random message 997] INFO [ConsumerRunner] No more message on tailer: ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-05, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e} 2020-09-11 23:08:53,246 [Nuxeo-Consumer-08-1396-Random message 993] INFO [ConsumerRunner] No record after: 5s on ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-08, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e}, terminating 2020-09-11 23:08:53,246 [Nuxeo-Consumer-08-1396-Random message 993] INFO [ConsumerRunner] No more message on tailer: ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-08, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e} 2020-09-11 23:08:53,247 [Nuxeo-Consumer-08-1396-Random message 993] WARN [Slf4jExceptionHandler$2] Cache should have been cleaned 2020-09-11 23:08:53,251 [Nuxeo-Consumer-07-1250-Random message 958] INFO [ConsumerRunner] No record after: 5s on ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-07, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e}, terminating 2020-09-11 23:08:53,252 [Nuxeo-Consumer-07-1250-Random message 958] INFO [ConsumerRunner] No more message on tailer: ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-07, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e} 2020-09-11 23:08:53,259 [Nuxeo-Consumer-06-1245-Random message 998] INFO [ConsumerRunner] No record after: 5s on ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-06, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e}, terminating 2020-09-11 23:08:53,259 [Nuxeo-Consumer-03-1258-Random message 994] INFO [ConsumerRunner] No record after: 5s on ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-03, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e}, terminating 2020-09-11 23:08:53,259 [Nuxeo-Consumer-06-1245-Random message 998] INFO [ConsumerRunner] No more message on tailer: ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-06, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e} 2020-09-11 23:08:53,259 [Nuxeo-Consumer-03-1258-Random message 994] INFO [ConsumerRunner] No more message on tailer: ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-03, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e} 2020-09-11 23:08:53,260 [Nuxeo-Consumer-02-1279-Random message 980] INFO [ConsumerRunner] No record after: 5s on ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-02, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e}, terminating 2020-09-11 23:08:53,260 [Nuxeo-Consumer-02-1279-Random message 980] INFO [ConsumerRunner] No more message on tailer: ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-02, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e} 2020-09-11 23:08:53,260 [Nuxeo-Consumer-01-1338-Random message 990] INFO [ConsumerRunner] No record after: 5s on ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-01, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e}, terminating 2020-09-11 23:08:53,260 [Nuxeo-Consumer-01-1338-Random message 990] INFO [ConsumerRunner] No more message on tailer: ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-01, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e} 2020-09-11 23:08:53,261 [Nuxeo-Consumer-00-1339-Random message 999] INFO [ConsumerRunner] No record after: 5s on ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-00, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e}, terminating 2020-09-11 23:08:53,261 [Nuxeo-Consumer-00-1339-Random message 999] INFO [ConsumerRunner] No more message on tailer: ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-00, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e} 2020-09-11 23:08:53,262 [Nuxeo-Consumer-00-1339-Random message 999] WARN [Slf4jExceptionHandler$2] Cache should have been cleaned 2020-09-11 23:08:53,262 [Nuxeo-ConsumerPool-00] INFO [ArrayList] Consumer ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-00, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e} status: accepted (include retries): 1340, committed: 1340, batch: 135, batchFailure: 0, elapsed: 6.00s, throughput: 223.41 msg/s. 2020-09-11 23:08:53,262 [Nuxeo-ConsumerPool-00] INFO [ArrayList] Consumer ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-01, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e} status: accepted (include retries): 1339, committed: 1339, batch: 134, batchFailure: 0, elapsed: 5.84s, throughput: 229.36 msg/s. 2020-09-11 23:08:53,262 [Nuxeo-ConsumerPool-00] INFO [ArrayList] Consumer ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-02, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e} status: accepted (include retries): 1280, committed: 1280, batch: 129, batchFailure: 0, elapsed: 5.84s, throughput: 219.33 msg/s. 2020-09-11 23:08:53,262 [Nuxeo-ConsumerPool-00] INFO [ArrayList] Consumer ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-03, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e} status: accepted (include retries): 1259, committed: 1259, batch: 126, batchFailure: 0, elapsed: 6.00s, throughput: 209.83 msg/s. 2020-09-11 23:08:53,262 [Nuxeo-ConsumerPool-00] INFO [ArrayList] Consumer ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-04, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e} status: accepted (include retries): 1317, committed: 1317, batch: 132, batchFailure: 0, elapsed: 5.98s, throughput: 220.42 msg/s. 2020-09-11 23:08:53,262 [Nuxeo-ConsumerPool-00] INFO [ArrayList] Consumer ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-05, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e} status: accepted (include retries): 1228, committed: 1228, batch: 123, batchFailure: 0, elapsed: 5.73s, throughput: 214.46 msg/s. 2020-09-11 23:08:53,263 [Nuxeo-ConsumerPool-00] INFO [ArrayList] Consumer ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-06, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e} status: accepted (include retries): 1246, committed: 1246, batch: 125, batchFailure: 0, elapsed: 5.63s, throughput: 221.24 msg/s. 2020-09-11 23:08:53,263 [Nuxeo-ConsumerPool-00] INFO [ArrayList] Consumer ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-07, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e} status: accepted (include retries): 1251, committed: 1251, batch: 126, batchFailure: 0, elapsed: 5.53s, throughput: 226.22 msg/s. 2020-09-11 23:08:53,263 [Nuxeo-ConsumerPool-00] INFO [ArrayList] Consumer ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-08, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e} status: accepted (include retries): 1397, committed: 1397, batch: 140, batchFailure: 0, elapsed: 5.44s, throughput: 257.04 msg/s. 2020-09-11 23:08:53,263 [Nuxeo-ConsumerPool-00] INFO [ArrayList] Consumer ChronicleLogTailer{basePath='target-postgresql/junit5097951718192540867/junit12060547623164568658/logName', id=default:logName-09, closed=false, codec=org.nuxeo.lib.stream.codec.NoCodec@919668e} status: accepted (include retries): 1380, committed: 1380, batch: 139, batchFailure: 0, elapsed: 5.43s, throughput: 254.05 msg/s. 2020-09-11 23:08:53,263 [Nuxeo-ConsumerPool-00] WARN [ConsumerPool] Consumers status: threads: 10, failure 0, messages committed: 13037, elapsed: 6.00s, throughput: 2172.11 msg/s 2020-09-11 23:08:53,269 [Nuxeo-Consumer-01-0-rebalance-revoked] WARN [Slf4jExceptionHandler$2] Cache should have been cleaned 2020-09-11 23:08:53,271 [Nuxeo-Consumer-01-0-rebalance-revoked] WARN [Slf4jExceptionHandler$2] Cache should have been cleaned