Hi I am using new asyc java producer , after couple of minutes i am getting following error
prio=5 os_prio=31 tid=0x00007f9383685800 nid=0xea03 waiting for monitor entry [0x0000000123a6a000] java.lang.Thread.State: BLOCKED (on object monitor) at org.xerial.snappy.buffer.CachedBufferAllocator.allocate(CachedBufferAllocator.java:46) - waiting to lock <0x0000000740c43790> (a org.xerial.snappy.buffer.CachedBufferAllocator) at org.xerial.snappy.SnappyOutputStream.<init>(SnappyOutputStream.java:95) at org.xerial.snappy.SnappyOutputStream.<init>(SnappyOutputStream.java:83) at sun.reflect.GeneratedConstructorAccessor27.newInstance(Unknown Source) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.lang.reflect.Constructor.newInstance(Constructor.java:408) at org.apache.kafka.common.record.Compressor.wrapForOutput(Compressor.java:213) at org.apache.kafka.common.record.Compressor.<init>(Compressor.java:73) at org.apache.kafka.common.record.Compressor.<init>(Compressor.java:77) at org.apache.kafka.common.record.MemoryRecords.<init>(MemoryRecords.java:43) at org.apache.kafka.common.record.MemoryRecords.emptyRecords(MemoryRecords.java:51) at org.apache.kafka.clients.producer.internals.RecordAccumulator.append(RecordAccumulator.java:169) - locked <0x0000000740c501e8> (a java.util.ArrayDeque) at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:338)