inline-transformation¶
This example will receive the message from a Flume Avro Sink which has a value of bytes. The FIX transformation will read the value of the record and replace the value with a Kafka Connect Struct based on the FIX message it received.
Tip
This example is specific to converting FIX financial data, however this pattern can be used to convert data before it is written to Kafka.
Note
This example requires the plugin containing com.github.jcustenborder.kafka.connect.transform.fix.FromFIX$Value to be available in the plugin path on the connect worker.
Configuration¶
{
"connector.class" : "com.github.jcustenborder.kafka.connect.flume.FlumeAvroSourceConnector",
"topic" : "flume",
"ip.filter.rules" : "allow:ip:127.*,allow:name:localhost,deny:ip:*",
"transforms" : "FromFix",
"transforms.FromFix.type" : "com.github.jcustenborder.kafka.connect.transform.fix.FromFIX$Value"
}
Data similar to the following will be emitted by this connector.
Output¶
{
"topic" : "test",
"kafkaPartition" : 1,
"keySchema" : {
"type" : "STRING",
"isOptional" : true
},
"key" : "asdf",
"valueSchema" : {
"name" : "fix42.NewOrderSingle",
"type" : "STRUCT",
"isOptional" : false,
"fieldSchemas" : {
"Account" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "1"
},
"isOptional" : true
},
"CashOrderQty" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "152"
},
"isOptional" : true
},
"CheckSum" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "10"
},
"isOptional" : true
},
"ClOrdID" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "11"
},
"isOptional" : true
},
"ClearingAccount" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "440"
},
"isOptional" : true
},
"ClearingFirm" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "439"
},
"isOptional" : true
},
"ClientID" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "109"
},
"isOptional" : true
},
"CommType" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "13"
},
"isOptional" : true
},
"Commission" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "12"
},
"isOptional" : true
},
"ComplianceID" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "376"
},
"isOptional" : true
},
"ContractMultiplier" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "231"
},
"isOptional" : true
},
"CouponRate" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "223"
},
"isOptional" : true
},
"CoveredOrUncovered" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "203"
},
"isOptional" : true
},
"Currency" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "15"
},
"isOptional" : true
},
"CustomerOrFirm" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "204"
},
"isOptional" : true
},
"DiscretionInst" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "388"
},
"isOptional" : true
},
"DiscretionOffset" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "389"
},
"isOptional" : true
},
"EffectiveTime" : {
"name" : "org.apache.kafka.connect.data.Timestamp",
"type" : "INT64",
"version" : 1,
"parameters" : {
"fix.field" : "168"
},
"isOptional" : true
},
"EncodedIssuer" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "349"
},
"isOptional" : true
},
"EncodedIssuerLen" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "348"
},
"isOptional" : true
},
"EncodedSecurityDesc" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "351"
},
"isOptional" : true
},
"EncodedSecurityDescLen" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "350"
},
"isOptional" : true
},
"EncodedText" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "355"
},
"isOptional" : true
},
"EncodedTextLen" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "354"
},
"isOptional" : true
},
"ExDestination" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "100"
},
"isOptional" : true
},
"ExecBroker" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "76"
},
"isOptional" : true
},
"ExecInst" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "18"
},
"isOptional" : true
},
"ExpireDate" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "432"
},
"isOptional" : true
},
"ExpireTime" : {
"name" : "org.apache.kafka.connect.data.Timestamp",
"type" : "INT64",
"version" : 1,
"parameters" : {
"fix.field" : "126"
},
"isOptional" : true
},
"ForexReq" : {
"type" : "BOOLEAN",
"parameters" : {
"fix.field" : "121"
},
"isOptional" : true
},
"FutSettDate" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "64"
},
"isOptional" : true
},
"FutSettDate2" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "193"
},
"isOptional" : true
},
"GTBookingInst" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "427"
},
"isOptional" : true
},
"HandlInst" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "21"
},
"isOptional" : true
},
"IDSource" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "22"
},
"isOptional" : true
},
"IOIID" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "23"
},
"isOptional" : true
},
"Issuer" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "106"
},
"isOptional" : true
},
"LocateReqd" : {
"type" : "BOOLEAN",
"parameters" : {
"fix.field" : "114"
},
"isOptional" : true
},
"MaturityDay" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "205"
},
"isOptional" : true
},
"MaturityMonthYear" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "200"
},
"isOptional" : true
},
"MaxFloor" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "111"
},
"isOptional" : true
},
"MaxShow" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "210"
},
"isOptional" : true
},
"MinQty" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "110"
},
"isOptional" : true
},
"NoAllocs" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "78"
},
"isOptional" : true
},
"NoTradingSessions" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "386"
},
"isOptional" : true
},
"OpenClose" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "77"
},
"isOptional" : true
},
"OptAttribute" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "206"
},
"isOptional" : true
},
"OrdType" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "40"
},
"isOptional" : true
},
"OrderQty" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "38"
},
"isOptional" : true
},
"OrderQty2" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "192"
},
"isOptional" : true
},
"PegDifference" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "211"
},
"isOptional" : true
},
"PrevClosePx" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "140"
},
"isOptional" : true
},
"Price" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "44"
},
"isOptional" : true
},
"ProcessCode" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "81"
},
"isOptional" : true
},
"PutOrCall" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "201"
},
"isOptional" : true
},
"QuoteID" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "117"
},
"isOptional" : true
},
"Rule80A" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "47"
},
"isOptional" : true
},
"SecurityDesc" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "107"
},
"isOptional" : true
},
"SecurityExchange" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "207"
},
"isOptional" : true
},
"SecurityID" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "48"
},
"isOptional" : true
},
"SecurityType" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "167"
},
"isOptional" : true
},
"SettlCurrency" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "120"
},
"isOptional" : true
},
"SettlmntTyp" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "63"
},
"isOptional" : true
},
"Side" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "54"
},
"isOptional" : true
},
"Signature" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "89"
},
"isOptional" : true
},
"SignatureLength" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "93"
},
"isOptional" : true
},
"SolicitedFlag" : {
"type" : "BOOLEAN",
"parameters" : {
"fix.field" : "377"
},
"isOptional" : true
},
"StopPx" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "99"
},
"isOptional" : true
},
"StrikePrice" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "202"
},
"isOptional" : true
},
"Symbol" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "55"
},
"isOptional" : true
},
"SymbolSfx" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "65"
},
"isOptional" : true
},
"Text" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "58"
},
"isOptional" : true
},
"TimeInForce" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "59"
},
"isOptional" : true
},
"TransactTime" : {
"name" : "org.apache.kafka.connect.data.Timestamp",
"type" : "INT64",
"version" : 1,
"parameters" : {
"fix.field" : "60"
},
"isOptional" : true
}
}
},
"value" : {
"schema" : {
"name" : "fix42.NewOrderSingle",
"type" : "STRUCT",
"isOptional" : false,
"fieldSchemas" : {
"Account" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "1"
},
"isOptional" : true
},
"CashOrderQty" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "152"
},
"isOptional" : true
},
"CheckSum" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "10"
},
"isOptional" : true
},
"ClOrdID" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "11"
},
"isOptional" : true
},
"ClearingAccount" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "440"
},
"isOptional" : true
},
"ClearingFirm" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "439"
},
"isOptional" : true
},
"ClientID" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "109"
},
"isOptional" : true
},
"CommType" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "13"
},
"isOptional" : true
},
"Commission" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "12"
},
"isOptional" : true
},
"ComplianceID" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "376"
},
"isOptional" : true
},
"ContractMultiplier" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "231"
},
"isOptional" : true
},
"CouponRate" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "223"
},
"isOptional" : true
},
"CoveredOrUncovered" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "203"
},
"isOptional" : true
},
"Currency" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "15"
},
"isOptional" : true
},
"CustomerOrFirm" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "204"
},
"isOptional" : true
},
"DiscretionInst" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "388"
},
"isOptional" : true
},
"DiscretionOffset" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "389"
},
"isOptional" : true
},
"EffectiveTime" : {
"name" : "org.apache.kafka.connect.data.Timestamp",
"type" : "INT64",
"version" : 1,
"parameters" : {
"fix.field" : "168"
},
"isOptional" : true
},
"EncodedIssuer" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "349"
},
"isOptional" : true
},
"EncodedIssuerLen" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "348"
},
"isOptional" : true
},
"EncodedSecurityDesc" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "351"
},
"isOptional" : true
},
"EncodedSecurityDescLen" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "350"
},
"isOptional" : true
},
"EncodedText" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "355"
},
"isOptional" : true
},
"EncodedTextLen" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "354"
},
"isOptional" : true
},
"ExDestination" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "100"
},
"isOptional" : true
},
"ExecBroker" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "76"
},
"isOptional" : true
},
"ExecInst" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "18"
},
"isOptional" : true
},
"ExpireDate" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "432"
},
"isOptional" : true
},
"ExpireTime" : {
"name" : "org.apache.kafka.connect.data.Timestamp",
"type" : "INT64",
"version" : 1,
"parameters" : {
"fix.field" : "126"
},
"isOptional" : true
},
"ForexReq" : {
"type" : "BOOLEAN",
"parameters" : {
"fix.field" : "121"
},
"isOptional" : true
},
"FutSettDate" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "64"
},
"isOptional" : true
},
"FutSettDate2" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "193"
},
"isOptional" : true
},
"GTBookingInst" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "427"
},
"isOptional" : true
},
"HandlInst" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "21"
},
"isOptional" : true
},
"IDSource" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "22"
},
"isOptional" : true
},
"IOIID" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "23"
},
"isOptional" : true
},
"Issuer" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "106"
},
"isOptional" : true
},
"LocateReqd" : {
"type" : "BOOLEAN",
"parameters" : {
"fix.field" : "114"
},
"isOptional" : true
},
"MaturityDay" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "205"
},
"isOptional" : true
},
"MaturityMonthYear" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "200"
},
"isOptional" : true
},
"MaxFloor" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "111"
},
"isOptional" : true
},
"MaxShow" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "210"
},
"isOptional" : true
},
"MinQty" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "110"
},
"isOptional" : true
},
"NoAllocs" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "78"
},
"isOptional" : true
},
"NoTradingSessions" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "386"
},
"isOptional" : true
},
"OpenClose" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "77"
},
"isOptional" : true
},
"OptAttribute" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "206"
},
"isOptional" : true
},
"OrdType" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "40"
},
"isOptional" : true
},
"OrderQty" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "38"
},
"isOptional" : true
},
"OrderQty2" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "192"
},
"isOptional" : true
},
"PegDifference" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "211"
},
"isOptional" : true
},
"PrevClosePx" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "140"
},
"isOptional" : true
},
"Price" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "44"
},
"isOptional" : true
},
"ProcessCode" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "81"
},
"isOptional" : true
},
"PutOrCall" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "201"
},
"isOptional" : true
},
"QuoteID" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "117"
},
"isOptional" : true
},
"Rule80A" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "47"
},
"isOptional" : true
},
"SecurityDesc" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "107"
},
"isOptional" : true
},
"SecurityExchange" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "207"
},
"isOptional" : true
},
"SecurityID" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "48"
},
"isOptional" : true
},
"SecurityType" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "167"
},
"isOptional" : true
},
"SettlCurrency" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "120"
},
"isOptional" : true
},
"SettlmntTyp" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "63"
},
"isOptional" : true
},
"Side" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "54"
},
"isOptional" : true
},
"Signature" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "89"
},
"isOptional" : true
},
"SignatureLength" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "93"
},
"isOptional" : true
},
"SolicitedFlag" : {
"type" : "BOOLEAN",
"parameters" : {
"fix.field" : "377"
},
"isOptional" : true
},
"StopPx" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "99"
},
"isOptional" : true
},
"StrikePrice" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "202"
},
"isOptional" : true
},
"Symbol" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "55"
},
"isOptional" : true
},
"SymbolSfx" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "65"
},
"isOptional" : true
},
"Text" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "58"
},
"isOptional" : true
},
"TimeInForce" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "59"
},
"isOptional" : true
},
"TransactTime" : {
"name" : "org.apache.kafka.connect.data.Timestamp",
"type" : "INT64",
"version" : 1,
"parameters" : {
"fix.field" : "60"
},
"isOptional" : true
}
}
},
"fieldValues" : [ {
"name" : "Account",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "1"
},
"isOptional" : true
}
}, {
"name" : "CashOrderQty",
"schema" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "152"
},
"isOptional" : true
}
}, {
"name" : "CheckSum",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "10"
},
"isOptional" : true
}
}, {
"name" : "ClOrdID",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "11"
},
"isOptional" : true
},
"storage" : "NF 0542/03232009"
}, {
"name" : "ClearingAccount",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "440"
},
"isOptional" : true
}
}, {
"name" : "ClearingFirm",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "439"
},
"isOptional" : true
}
}, {
"name" : "ClientID",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "109"
},
"isOptional" : true
}
}, {
"name" : "CommType",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "13"
},
"isOptional" : true
}
}, {
"name" : "Commission",
"schema" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "12"
},
"isOptional" : true
}
}, {
"name" : "ComplianceID",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "376"
},
"isOptional" : true
}
}, {
"name" : "ContractMultiplier",
"schema" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "231"
},
"isOptional" : true
}
}, {
"name" : "CouponRate",
"schema" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "223"
},
"isOptional" : true
}
}, {
"name" : "CoveredOrUncovered",
"schema" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "203"
},
"isOptional" : true
}
}, {
"name" : "Currency",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "15"
},
"isOptional" : true
}
}, {
"name" : "CustomerOrFirm",
"schema" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "204"
},
"isOptional" : true
}
}, {
"name" : "DiscretionInst",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "388"
},
"isOptional" : true
}
}, {
"name" : "DiscretionOffset",
"schema" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "389"
},
"isOptional" : true
}
}, {
"name" : "EffectiveTime",
"schema" : {
"name" : "org.apache.kafka.connect.data.Timestamp",
"type" : "INT64",
"version" : 1,
"parameters" : {
"fix.field" : "168"
},
"isOptional" : true
}
}, {
"name" : "EncodedIssuer",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "349"
},
"isOptional" : true
}
}, {
"name" : "EncodedIssuerLen",
"schema" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "348"
},
"isOptional" : true
}
}, {
"name" : "EncodedSecurityDesc",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "351"
},
"isOptional" : true
}
}, {
"name" : "EncodedSecurityDescLen",
"schema" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "350"
},
"isOptional" : true
}
}, {
"name" : "EncodedText",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "355"
},
"isOptional" : true
}
}, {
"name" : "EncodedTextLen",
"schema" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "354"
},
"isOptional" : true
}
}, {
"name" : "ExDestination",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "100"
},
"isOptional" : true
}
}, {
"name" : "ExecBroker",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "76"
},
"isOptional" : true
}
}, {
"name" : "ExecInst",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "18"
},
"isOptional" : true
}
}, {
"name" : "ExpireDate",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "432"
},
"isOptional" : true
}
}, {
"name" : "ExpireTime",
"schema" : {
"name" : "org.apache.kafka.connect.data.Timestamp",
"type" : "INT64",
"version" : 1,
"parameters" : {
"fix.field" : "126"
},
"isOptional" : true
}
}, {
"name" : "ForexReq",
"schema" : {
"type" : "BOOLEAN",
"parameters" : {
"fix.field" : "121"
},
"isOptional" : true
}
}, {
"name" : "FutSettDate",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "64"
},
"isOptional" : true
}
}, {
"name" : "FutSettDate2",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "193"
},
"isOptional" : true
}
}, {
"name" : "GTBookingInst",
"schema" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "427"
},
"isOptional" : true
}
}, {
"name" : "HandlInst",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "21"
},
"isOptional" : true
},
"storage" : "1"
}, {
"name" : "IDSource",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "22"
},
"isOptional" : true
}
}, {
"name" : "IOIID",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "23"
},
"isOptional" : true
}
}, {
"name" : "Issuer",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "106"
},
"isOptional" : true
}
}, {
"name" : "LocateReqd",
"schema" : {
"type" : "BOOLEAN",
"parameters" : {
"fix.field" : "114"
},
"isOptional" : true
}
}, {
"name" : "MaturityDay",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "205"
},
"isOptional" : true
}
}, {
"name" : "MaturityMonthYear",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "200"
},
"isOptional" : true
}
}, {
"name" : "MaxFloor",
"schema" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "111"
},
"isOptional" : true
}
}, {
"name" : "MaxShow",
"schema" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "210"
},
"isOptional" : true
}
}, {
"name" : "MinQty",
"schema" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "110"
},
"isOptional" : true
}
}, {
"name" : "NoAllocs",
"schema" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "78"
},
"isOptional" : true
}
}, {
"name" : "NoTradingSessions",
"schema" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "386"
},
"isOptional" : true
}
}, {
"name" : "OpenClose",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "77"
},
"isOptional" : true
}
}, {
"name" : "OptAttribute",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "206"
},
"isOptional" : true
}
}, {
"name" : "OrdType",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "40"
},
"isOptional" : true
},
"storage" : "1"
}, {
"name" : "OrderQty",
"schema" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "38"
},
"isOptional" : true
},
"storage" : 100.0
}, {
"name" : "OrderQty2",
"schema" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "192"
},
"isOptional" : true
}
}, {
"name" : "PegDifference",
"schema" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "211"
},
"isOptional" : true
}
}, {
"name" : "PrevClosePx",
"schema" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "140"
},
"isOptional" : true
}
}, {
"name" : "Price",
"schema" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "44"
},
"isOptional" : true
}
}, {
"name" : "ProcessCode",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "81"
},
"isOptional" : true
}
}, {
"name" : "PutOrCall",
"schema" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "201"
},
"isOptional" : true
}
}, {
"name" : "QuoteID",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "117"
},
"isOptional" : true
}
}, {
"name" : "Rule80A",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "47"
},
"isOptional" : true
},
"storage" : "A"
}, {
"name" : "SecurityDesc",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "107"
},
"isOptional" : true
}
}, {
"name" : "SecurityExchange",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "207"
},
"isOptional" : true
},
"storage" : "N"
}, {
"name" : "SecurityID",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "48"
},
"isOptional" : true
}
}, {
"name" : "SecurityType",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "167"
},
"isOptional" : true
}
}, {
"name" : "SettlCurrency",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "120"
},
"isOptional" : true
}
}, {
"name" : "SettlmntTyp",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "63"
},
"isOptional" : true
}
}, {
"name" : "Side",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "54"
},
"isOptional" : true
},
"storage" : "1"
}, {
"name" : "Signature",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "89"
},
"isOptional" : true
}
}, {
"name" : "SignatureLength",
"schema" : {
"type" : "INT32",
"parameters" : {
"fix.field" : "93"
},
"isOptional" : true
}
}, {
"name" : "SolicitedFlag",
"schema" : {
"type" : "BOOLEAN",
"parameters" : {
"fix.field" : "377"
},
"isOptional" : true
}
}, {
"name" : "StopPx",
"schema" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "99"
},
"isOptional" : true
}
}, {
"name" : "StrikePrice",
"schema" : {
"type" : "FLOAT64",
"parameters" : {
"fix.field" : "202"
},
"isOptional" : true
}
}, {
"name" : "Symbol",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "55"
},
"isOptional" : true
},
"storage" : "CVS"
}, {
"name" : "SymbolSfx",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "65"
},
"isOptional" : true
}
}, {
"name" : "Text",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "58"
},
"isOptional" : true
}
}, {
"name" : "TimeInForce",
"schema" : {
"type" : "STRING",
"parameters" : {
"fix.field" : "59"
},
"isOptional" : true
},
"storage" : "0"
}, {
"name" : "TransactTime",
"schema" : {
"name" : "org.apache.kafka.connect.data.Timestamp",
"type" : "INT64",
"version" : 1,
"parameters" : {
"fix.field" : "60"
},
"isOptional" : true
},
"storage" : 1237822829000
} ]
},
"timestamp" : 1530286549123,
"headers" : [ {
"name" : "flume.header",
"schema" : {
"type" : "STRING",
"isOptional" : false
},
"storage" : "adsfasdf"
} ]
}