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)
