The excitement was almost palpable when we found this page. We have a bug where all looks good but SOMETIMES our topology fails everything with a timeout. So in went the topology.eventlogger.executors: 1 and with excitement we hit the "DEBUG" button. Much to our surprise, MessageId is not serializable: java.lang.RuntimeException: java.lang.RuntimeException: java.io.NotSerializableException: org.apache.storm.eventhubs.spout.MessageId at org.apache.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:464) at org.apache.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:430) at We are using Microsoft EHubs and their messageId is not Serializeable. So I have two questions: 1. Could we get this fixed? 2. How can anyone be using this?
... View more
