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)

Reply via email to