Kafka Data Flows

Owned by TonyC (Unlicensed)
Last updated: Nov 03, 2017
1 min read

Details on the records can be found at WYDOT Record Types and Deposits to Data Rpositories

Decoding Records

Record Type→ Encoded Stream→ Decoded Stream→ Java Object→ JSON Topic→ Filtered JSON Topic
driverAlertRecord

n/a

n/an/a

topic.OdeDriverAlertJson


bsmTxRecord

topic.Asn1DecoderInput

topic.Asn1DecoderOutput

topic.OdeBsmPojo

topic.OdeBsmTxPojo

topic.OdeBsmJson

topic.FilteredOdeBsmJson

bsmTxRecord for V2I, bsmTxRecord & bsmRxRecord for V2V

topic.Asn1DecoderInput

topic.Asn1DecoderOutput

topic.OdeBsmPojo

topic.OdeBsmDuringEventPojo 

topic.OdeBsmJson

topic.FilteredOdeBsmJson


receivedMsgRecord

topic.Asn1DecoderInput

topic.Asn1DecoderOutput

topic.OdeBsmPojo

topic.OdeBsmRxPojo


topic.OdeBsmJson

topic.OdeTimJson

topic.OdeTimRxJson

topic.FilteredOdeBsmJson

topic.FilteredOdeTimJson

dnmMsgRecord

topic.Asn1DecoderInput

topic.Asn1DecoderOutput

topic.OdeDNMsgPojo


topic.OdeDNMsgJson

topic.OdeTimJson

topic.FilteredOdeTimJson

Encoding Records

Record Type→ Decoded Stream→ Encoded Stream→ Java Object→ JSON Topic→ Filtered JSON Topic
Broadcast TIM topic.Asn1EncoderInputtopic.Asn1EncoderOutput

topic.OdeTimBroadcastPojo

topic.OdeTimBroadcastJson

n/a