jnioche commented on issue #2890: Dependencies for using Pulsar in Storm topologies URL: https://github.com/apache/pulsar/issues/2890#issuecomment-434257707 The exception is thrown here https://github.com/apache/pulsar/blob/b6a25f034bd8a9c3b30aa4a90eefdd45a0f0ee67/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java#L451 ``` Thread [pulsar-timer-10-1] (Suspended (breakpoint at line 948 in Commands)) owns: ProducerImpl<T> (id=1217043) Commands.serializeCommandSendWithSize(PulsarApi$BaseCommand$Builder, Commands$ChecksumType, PulsarApi$MessageMetadata, ByteBuf) line: 948 Commands.newSend(long, long, int, Commands$ChecksumType, PulsarApi$MessageMetadata, ByteBuf) line: 315 ProducerImpl<T>.sendMessage(long, long, int, PulsarApi$MessageMetadata, ByteBuf) line: 451 ProducerImpl<T>.batchMessageAndSend() line: 1291 ProducerImpl<T>.access$500(ProducerImpl) line: 78 ProducerImpl$2.run(Timeout) line: 1248 HashedWheelTimer$HashedWheelTimeout.expire() line: 663 HashedWheelTimer$HashedWheelBucket.expireTimeouts(long) line: 738 HashedWheelTimer$Worker.run() line: 466 FastThreadLocalRunnable.run() line: 30 FastThreadLocalThread(Thread).run() line: 748 ``` I can see that the library we are using at runtime contains _public static int computeChecksum(org.apache.pulsar.shade.io.netty.buffer.ByteBuf payload);_ whereas it is complaining about the lack of this signature `Crc32cIntChecksum.computeChecksum(Lio/netty/buffer/ByteBuf;)I` Could this be shading related?
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
