Missing required field: OrgId

[samtyagi]

trafficstars

Hello Team, We are setting up Haystack on the local system by not using Docker. When we are pushing the data , we can see trends on the UI. However, the data is not getting pushed to alerts.

For this we are receiving the error java.lang.RuntimeException: java.io.IOException: Missing required field: OrgId

We can see this check is part of MetricTankIdFactory which is part of error metrics-java-metrictank-0.11.0.jar. However, we are not sure shere this OrgID is being setup? Can you please help.

2021-01-28 20:29:01 WARN  RecordDeserializer:86 () - task [0_0] Skipping record due to deserialization error. topic=[metrics] partition=[0] offset=[1394]
java.lang.RuntimeException: java.io.IOException: Missing required field: OrgId
        at com.expedia.adaptivealerting.kafka.serde.MetricDataDeserializer.deserialize(MetricDataDeserializer.java:37)
        at com.expedia.adaptivealerting.kafka.serde.MetricDataDeserializer.deserialize(MetricDataDeserializer.java:23)
        at org.apache.kafka.common.serialization.Deserializer.deserialize(Deserializer.java:60)
        at org.apache.kafka.streams.processor.internals.SourceNode.deserializeValue(SourceNode.java:60)
        at org.apache.kafka.streams.processor.internals.RecordDeserializer.deserialize(RecordDeserializer.java:66)
        at org.apache.kafka.streams.processor.internals.RecordQueue.updateHead(RecordQueue.java:169)
        at org.apache.kafka.streams.processor.internals.RecordQueue.addRawRecords(RecordQueue.java:101)
        at org.apache.kafka.streams.processor.internals.PartitionGroup.addRawRecords(PartitionGroup.java:136)
        at org.apache.kafka.streams.processor.internals.StreamTask.addRecords(StreamTask.java:744)
        at org.apache.kafka.streams.processor.internals.StreamThread.addRecordsToTasks(StreamThread.java:1045)
        at org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:883)
        at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:819)
        at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:788)
Caused by: java.io.IOException: Missing required field: OrgId
        at com.expedia.metrics.metrictank.MessagePackSerializer.throwIfMissing(MessagePackSerializer.java:255)
        at com.expedia.metrics.metrictank.MessagePackSerializer.deserialize(MessagePackSerializer.java:233)
        at com.expedia.metrics.metrictank.MessagePackSerializer.deserialize(MessagePackSerializer.java:68)
        at com.expedia.metrics.metrictank.MessagePackSerializer.deserialize(MessagePackSerializer.java:79)
        at com.expedia.adaptivealerting.kafka.serde.MetricDataDeserializer.deserialize(MetricDataDeserializer.java:35)