Skip to main content

EMP Details Facility

Modern AVRO Schemas

These schemas are essential for producing and consuming EMP messages from our cloud APIs.

All Facility Master Data EMP topics are log-compacted, ensuring that all records are preserved on their respective topics indefinitely.

Applications should start consuming from the latest offset to prevent reloading all records.

If the service is set to consume from offset=zero, all records will be loaded into your database.

For tenant onboarding, please refer to the documentation.

V3 to V4 attribute comparison mapping:

Facility V4Facility V3Remarks
facilityIdentifierfacilityId
facilityNamename
typeThis attribute not exists in V4 due to this topic is currently having operational facilities and does not exist commercial facilities. Based on business and MIM need to maintain separate topic for commercial facility that;s reason not maintaing type
isOwnedByExternalPartyextOwned
isActivestatus
facilityStatusDescriptionFacility Status Description. This attribute is applicable only for LNS Facilities with status as In progress . Example: Cancelled,IP Approved and IP Preparation e.t.c
isExternallyExposedextExposed
facilityAvailabilityreceiptServiceMode
webPageAddressurl
doDAACThis attribute not exists in V4 due to no facility does not exist any doDAAC data that's the reason based on business/MIM removed this attribute
validToDatetimeThis is the new attribute onboarded in v4 only for operational facility valid through date.This attribute is applicable for operational facility only. When we inactivate facility automatically update system date. By default new facility date as "9999-12-31"
isGpsEnabledfacilityDetail ---> gpsFlag
isGsmEnabledfacilityDetail ---> gsmFlag
nameAliases --> nameAliasThis is the new attribute onboarded in v4 only for LNS operational facility . The alternate name of LNS Site {3 letters of ProductFamily code}_{3 letters of Area code}_{siteDescription}_({2 letters of OperationType code}). Example: DEP_IBS_Pune Warehouse_(JV)
postalAddress --> streetNumberaddress --> houseNumber
postalAddress --> streetNameaddress --> street
postalAddress --> cityaddress --> city
postalAddress --> postalCodeaddress --> postalCode
postalAddress --> subDivision --> subDivisionNameaddress ---> territory
postalAddress --> subDivision --> subDivisionCodeThis is the new attribute onboarded in v4 . Some of the consumers need state/province code.
postalAddress --> districtaddress ---> district
postalAddress --> countryNameaddress ---> countryName
postalAddress --> ISO2CountryCodeaddress ---> countryCode
postalAddress --> postalAddressLine2address ---> addressLine2
postalAddress --> postalAddressLine3address ---> addressLine3
postalAddress --> latitudeaddress ---> latitude
postalAddress --> longitudeaddress ---> longitude
address ---> addressQualityCheckIndicatorThis attribute not exists in V4 due to this attribute is not useful for business
Parties --> firstNamecontactDetails --> firstName
Parties --> lastNamecontactDetails --> lastName
Parties --> jobTitlecontactDetails --> jobTitle
Parties --> departmentcontactDetails --> department
Parties --> remarkThis is the new attribute onboarded in v4 only mainly for LNS facilities. They need to capture remark against contact details
Parties --> partyFunctionNameThis is the new attribute onboarded in v4 only . This attribute will tell Type of this contact. Example: Site manager,Technician
Parties --> telecommunicationNumbers --> telecommunicationNumberTypeThis is the new attribute onboarded in v4 only . This attribute will tell facility phone number type Example: Mobile,Telephone,Fax. In V3 we are maintaining individual attribute
Parties --> telecommunicationNumbers --> countryCallingCodecontactDetails --> internationalDialingCdPhonecontactDetails --> internationalDialingCdMobilecontactDetails -->internaltionalDialingCodeFaxIn V3 we are maintaining individual attribute but in v4 based on the telecommunication type user will enter the data.
Parties --> telecommunicationNumbers --> extensionNumbercontactDetails -->extension
Parties --> telecommunicationNumbers --> telecommunicationNumbercontactDetails --> phoneNumbercontactDetails --> mobileNumbercontactDetails -->faxNumberIn V3 we are maintaining individual attribute but in v4 based on the telecommunication type user will enter the data against telecommunication number.
Parties --> emailAddresses --> contactAddressPurposeNameThis is the new attribute onboarded in v4 only . This attribute will tell type of email.Example: Person,Import Enquiry and Export Enquiry
Parties --> emailAddresses --> emailAddresscontactDetails --> emailAddress
contactDetails --> validThroughDateThis attribute not exists in V4 due to this attribute is not useful for business
facilityRelationship --> nameparent --> name
facilityRelationship --> facilityTypeParentparent --> type
facilityRelationship --> alternativeCodes --> alternativeCodeparent --> alternateCodes --> code
facilityRelationship --> alternativeCodes --> alternativeCodeType -->AlternativeCodeType --> alternativeCodeTypeCodeparent --> alternateCodes --> codeType
facilityOfferings --> facilityOfferingCodefacilityServices --> serviceCode
facilityOfferings --> facilityOfferingNamefacilityServices --> serviceName
facilityOfferings --> facilityOfferingDescriptionfacilityServices --> serviceDescription
facilityOfferings --> validToDatetimefacilityServices --> validThroughDate
facilityOfferings --> isprimaryOfferingThis is the new attribute onboarded in v4 only mainly for LNS facilities. They need to capture wheather this service is primary ornot
facilityOfferings --> isDeletedThis is the new attribute onboarded in v4 only . This attribute will tell when ever the service is deleted.
facilityCapacities ---> capacityMeasurement --> capacityMeasurementCodeThis is the new attribute onboarded in v4 only . This attribute will tell capacity measurement code
facilityCapacities ---> capacityMeasurement --> capacityMeasurementNameThis is the new attribute onboarded in v4 only . This attribute will tell capacity measurement name like weightLimitCrane, weightLimitYard
facilityCapacities ---> valuefacilityDetail --> weightLimitCraneKg, facilityDetail --> weightLimitYardKg
facilityCapacities ---> valueUnit --> unitOfMeasurementCodeThis is the new attribute onboarded in v4 only . This attribute will tell capacity unit of measurement code against capacity Example: KG
facilityCapacities ---> valueUnit --> unitOfMeasurementNameThis is the new attribute onboarded in v4 only . This attribute will tell capacity unit of measurement Name against capacity Example: kilogram,square meter
facilityCertifications --> certificationDateThis is the new attribute onboarded in v4 only mainly for LNS facilities. They need to capture Certification details
facilityCertifications --> certificationNameThis is the new attribute onboarded in v4 only mainly for LNS facilities. They need to capture Certification details
facilityCertifications --> certificationType --> certificationTypeCodeThis is the new attribute onboarded in v4 only mainly for LNS facilities. They need to capture Certification details
facilityCertifications --> certificationType --> certificationTypeNameThis is the new attribute onboarded in v4 only mainly for LNS facilities. They need to capture Certification details
facilityCertifications --> certificationLevel --> certificationLevelCodeThis is the new attribute onboarded in v4 only mainly for LNS facilities. They need to capture Certification details
facilityCertifications --> certificationLevel --> certificationLevelNameThis is the new attribute onboarded in v4 only mainly for LNS facilities. They need to capture Certification details
masterFacilityType --> facilityTypeCodeThis is the new attribute onboarded in v4 only for future purpose currently all records will get null only
masterFacilityType --> facilityTypeNameThis is the new attribute onboarded in v4 only for future purpose currently all records will get null only
facilityTypes --> facilityTypeCodefacilityDetail --> facilityTypes --> code
facilityTypes --> facilityTypeNamefacilityDetail --> facilityTypes --> name
FacilityTypes ---> isDeletedThis is the new attribute onboarded in v4 only . This attribute will tell when ever the facility type is deleted.
facilityDetail --> facilityTypes --> masterTypeThis attribute not exists in V4 due to this attribute is not useful for business
facilityDetail --> facilityTypes --> validThroughDateThis attribute not exists in V4 due to this attribute is not useful for business instead maintaining is deleted flag
definedAreas --> definedAreaNamebdas --> name
definedAreas --> locationTypebdas --> type
definedAreas --> definedAreaTypeCodebdas --> bdaType
definedAreas --> alternativeCodes --> alternativeCodebdas --> alternateCodes --> code
definedAreas --> alternativeCodes --> alternativeCodeType -->AlternativeCodeType --> alternativeCodeTypeCodebdas --> alternateCodes --> codeType
alternativeCodes --> alternativeCodealternateCodes --> code
alternativeCodes --> alternativeCodeType -->AlternativeCodeType --> alternativeCodeTypeCodealternateCodes --> codeType
facilityAvailabilities --> availabilityStartTimeopeningHours --> openTimeHours, openingHours --> openTimeMinutesDisplay with the format. Example: 08:00
facilityAvailabilities --> availabilityEndTimeopeningHours --> closeTimeHours, openingHours --> closeTimeMinutesDisplay with the format. Example: 08:00
facilityAvailabilities --> facilityAvailabilityType --> facilityAvailabilityTypeCodeThis is the new attribute onboarded in v4 only . This attribute will tell the facility availability type code information. Example: OH
facilityAvailabilities --> facilityAvailabilityType --> facilityAvailabilityTypeNameThis is the new attribute onboarded in v4 only . This attribute will tell the facility availability type name information. Example: Opening Hours
facilityAvailabilities --> weekdaysopeningHours --> day
facilityAvailabilities --> isDeletedThis is the new attribute onboarded in v4 only . This attribute will tell when ever the facility availibility is deleted.
accessByTransportModes --> transportModeCodetransportModes --> transportModeCode
accessByTransportModes --> transportModeNametransportModes --> modeOfTransport
accessByTransportModes --> validToDatetimetransportModes --> validThroughDate
accessByTransportModes --> isDeletedThis is the new attribute onboarded in v4 only . This attribute will tell when ever the facility transport mode is deleted.
transportModes --> transportDescriptionThis attribute not exists in V4 due to this attribute is not useful for business. If any one want need to concatenate transportmodecode and modeofTransport
brandfacilityDetail --> brandThis attribute is useful for commercial fgacilities only. For OPS facility always get null
AssetValidFromDateThis is the new attribute onboarded in v4 only mainly for LNS facilities.
validFromDatetimeThis is the new attribute onboarded in v4 only for operational facility valid through date.This attribute is applicable for operational facility only. When we active facility automatically update system date. By default new facility date as "1900-01-01"
investmentProposalSubmissionDateThis is the new attribute onboarded in v4 only mainly for LNS facilities.
isFacilityTerminatedAtValidToDateThis is the new attribute onboarded in v4 only mainly for LNS facilities.
assetOwnershipTypeThis is the new attribute onboarded in v4 only mainly for LNS facilities.
operationalFacilityOwnershipThis is the new attribute onboarded in v4 only mainly for LNS facilities.
capacityModel3plThis is the new attribute onboarded in v4 only mainly for LNS facilities.
previousBrandsThis is the new attribute onboarded in v4 only mainly for LNS facilities.
leaseCommitmentValueThis is the new attribute onboarded in v4 only mainly for LNS facilities.
investmentProposalApprovedCapexThis is the new attribute onboarded in v4 only mainly for LNS facilities.
clusterIdentifierThis is the new attribute onboarded in v4 only mainly for LNS facilities.
isStandaloneThis is the new attribute onboarded in v4 only mainly for LNS facilities.
createUserIdThis is the new attribute onboarded in v4 only. Audit Attribute capture Facility creation user id
createTimestampThis is the new attribute onboarded in v4 only. Audit Attribute capture Facility creation timestamp
updateUserIdThis is the new attribute onboarded in v4 only. Audit Attribute capture Facility creation user id
updateTimestampThis is the new attribute onboarded in v4 only. Audit Attribute capture Facility creation timestamp
updateSourceThis is the new attribute onboarded in v4 only. This attribute should capture this facility is related to WND(Lns) or Ocean

Facility- V3

{
"facility": {
"facilityId": "BJBN7K1I7AD4U",
"name": "Expogranel Guatemala",
"type": "OperationalFacility",
"extOwned": true,
"status": "Active",
"extExposed": true,
"address": {
"street": {
"string": "Km 100 Carretera a Puerto Quetzal"
},
"city": "Puerto Quetzal",
"postalCode": {
"string": "05001"
},
"countryName": "Guatemala",
"countryCode": "GT",
"addressLine2": {
"string": "A un Costado de Parque Las Palmas"
},
"latitude": {
"string": "13.935810"
},
"longitude": {
"string": "-90.788570"
},
"addressQualityCheckIndicator": "Do not Check"
},
"parent": {
"name": "Puerto Quetzal",
"type": "City",
"alternateCodes": [
{
"codeType": "RKST",
"code": "GTTGZ"
},
{
"codeType": "CARGOWISE1 CODE",
"code": "GTPRQ"
},
{
"codeType": "CW1 FUNCTION CODE",
"code": "GTPRQ(0,1,0,0)"
},
{
"codeType": "LNS CODE",
"code": "GTTGZ"
},
{
"codeType": "LNS UN CODE",
"code": "GTPRQ"
},
{
"codeType": "GEOID",
"code": "1E3PT92HVMD1B"
},
{
"codeType": "UN CODE",
"code": "GTPRQ"
},
{
"codeType": "SCHEDULE K",
"code": "20506"
},
{
"codeType": "HSUD CODE",
"code": "GTPRQ00"
},
{
"codeType": "LNS GEOID",
"code": "1E3PT92HVMD1B"
},
{
"codeType": "HSUD NUMBER",
"code": "100056671"
},
{
"codeType": "RKTS",
"code": "PUZ"
}
]
},
"facilityDetail": {
"facilityDetail": {
"vesselAgent": {
"string": "NO"
},
"gpsFlag": {
"string": "NO"
},
"gsmFlag": {
"string": "NO"
},
"oceanFreightPricing": {
"string": "NO"
},
"facilityTypes": {
"array": [
{
"code": "FCT_OPS_TYPE.ICD",
"name": "Inland Container Depot",
"masterType": "Facility type",
"validThroughDate": "9999-12-31"
}
]
}
}
},
"alternateCodes": [
{
"codeType": "RKST",
"code": "GTTGZEG"
},
{
"codeType": "UN CODE(Return Only)",
"code": "GTPRQ"
},
{
"codeType": "GEOID",
"code": "BJBN7K1I7AD4U"
}
],
"facilityServices": {
"array": [
{
"serviceName": "Intermodal services available: Truck",
"serviceCode": "INTM",
"serviceDescription": " - Intermodal services available: Truck",
"validThroughDate": "9999-12-31"
}
]
},
"bdas": {
"array": [
{
"name": "GTTGZ",
"type": "Business Defined Area",
"bdaType": "POOL",
"alternateCodes": [
{
"codeType": "GEOID",
"code": "KRJFTWO5INV7L"
},
{
"codeType": "BDA CODE",
"code": "GTTGZ"
}
]
}
]
}
}
}

Facility - V4

{
"facilityIdentifier": "BJBN7K1I7AD4U",
"facilityName": "Expogranel Guatemala",
"isOwnedByExternalParty": true,
"isActive": {
"boolean": true
},
"facilityStatusDescription": "",
"isExternallyExposed": true,
"validToDatetime": "9999-12-31",
"isGpsEnabled": {
"boolean": false
},
"isGsmEnabled": {
"boolean": false
},
"postalAddress": {
"postalAddressCombined": {
"streetName": {
"string": "Km 100 Carretera a Puerto Quetzal"
},
"city": "Puerto Quetzal",
"postalCode": {
"string": "05001"
},
"subDivision": {
"subDivision": {}
},
"countryName": "Guatemala",
"ISO2CountryCode": "GT",
"postalAddressLine2": {
"string": "A un Costado de Parque Las Palmas"
},
"latitude": {
"string": "13.935810"
},
"longitude": {
"string": "-90.788570"
}
}
},
"facilityRelationship": {
"name": "Puerto Quetzal",
"facilityTypeParent": "City",
"alternativeCodes": [
{
"alternativeCode": {
"string": "GTTGZ"
},
"alternativeCodeType": {
"AlternativeCodeType": {
"alternativeCodeTypeCode": {
"string": "ALT_CODE.RKST"
}
}
}
},
{
"alternativeCode": {
"string": "GTPRQ"
},
"alternativeCodeType": {
"AlternativeCodeType": {
"alternativeCodeTypeCode": {
"string": "ALT_CODE.CW1_CODE"
}
}
}
},
{
"alternativeCode": {
"string": "GTPRQ(0,1,0,0)"
},
"alternativeCodeType": {
"AlternativeCodeType": {
"alternativeCodeTypeCode": {
"string": "ALT_CODE.CW1_FCODE"
}
}
}
},
{
"alternativeCode": {
"string": "GTTGZ"
},
"alternativeCodeType": {
"AlternativeCodeType": {
"alternativeCodeTypeCode": {
"string": "ALT_CODE.LNS_CODE"
}
}
}
},
{
"alternativeCode": {
"string": "GTPRQ"
},
"alternativeCodeType": {
"AlternativeCodeType": {
"alternativeCodeTypeCode": {
"string": "ALT_CODE.LNS_UN_CODE"
}
}
}
},
{
"alternativeCode": {
"string": "1E3PT92HVMD1B"
},
"alternativeCodeType": {
"AlternativeCodeType": {
"alternativeCodeTypeCode": {
"string": "ALT_CODE.GEOID"
}
}
}
},
{
"alternativeCode": {
"string": "GTPRQ"
},
"alternativeCodeType": {
"AlternativeCodeType": {
"alternativeCodeTypeCode": {
"string": "ALT_CODE.UN_CODE"
}
}
}
},
{
"alternativeCode": {
"string": "20506"
},
"alternativeCodeType": {
"AlternativeCodeType": {
"alternativeCodeTypeCode": {
"string": "ALT_CODE.Schedule_K"
}
}
}
},
{
"alternativeCode": {
"string": "GTPRQ00"
},
"alternativeCodeType": {
"AlternativeCodeType": {
"alternativeCodeTypeCode": {
"string": "ALT_CODE.HSUD_CODE"
}
}
}
},
{
"alternativeCode": {
"string": "1E3PT92HVMD1B"
},
"alternativeCodeType": {
"AlternativeCodeType": {
"alternativeCodeTypeCode": {
"string": "ALT_CODE.LNS_GEOID"
}
}
}
},
{
"alternativeCode": {
"string": "100056671"
},
"alternativeCodeType": {
"AlternativeCodeType": {
"alternativeCodeTypeCode": {
"string": "ALT_CODE.HSUD_NUM"
}
}
}
},
{
"alternativeCode": {
"string": "PUZ"
},
"alternativeCodeType": {
"AlternativeCodeType": {
"alternativeCodeTypeCode": {
"string": "ALT_CODE.RKTS"
}
}
}
}
]
},
"facilityOfferings": {
"array": [
{
"facilityOfferingCode": "INTM",
"facilityOfferingName": "Intermodal services available: Truck",
"facilityOfferingDescription": " - Intermodal services available: Truck",
"validToDatetime": "9999-12-31",
"isprimaryOffering": false,
"isDeleted": false
}
]
},
"facilityTypes": {
"array": [
{
"facilityTypeCode": {
"string": "FCT_OPS_TYPE.ICD"
},
"facilityTypeName": "Inland Container Depot",
"FacilityTypeParent": {
"FacilityTypeParent": {
"facilityTypeCode": {
"string": "OPS"
},
"facilityTypeName": "OperationalFacility"
}
},
"isDeleted": false
}
]
},
"definedAreas": {
"array": []
},
"alternativeCodes": {
"array": [
{
"alternativeCode": {
"string": "GTTGZEG"
},
"alternativeCodeType": {
"AlternativeCodeType": {
"alternativeCodeTypeCode": {
"string": "ALT_CODE.RKST"
},
"alternativeCodeTypeName": {
"string": "RKST"
}
}
},
"isDeleted": false
},
{
"alternativeCode": {
"string": "GTPRQ"
},
"alternativeCodeType": {
"AlternativeCodeType": {
"alternativeCodeTypeCode": {
"string": "ALT_CODE.UN_CODE2"
},
"alternativeCodeTypeName": {
"string": "UN CODE(Return Only)"
}
}
},
"isDeleted": false
},
{
"alternativeCode": {
"string": "BJBN7K1I7AD4U"
},
"alternativeCodeType": {
"AlternativeCodeType": {
"alternativeCodeTypeCode": {
"string": "ALT_CODE.GEOID"
},
"alternativeCodeTypeName": {
"string": "GEOID"
}
}
},
"isDeleted": false
}
]
},
"isFacilityTerminatedAtValidToDate": false,
"isStandalone": true,
"createUserId": {
"string": "noellyn.villar.jasa@maersk.com"
},
"createTimestamp": {
"long": 1740088519669
},
"updateUserId": {
"string": "noellyn.villar.jasa@maersk.com"
},
"updateTimestamp": {
"long": 1740088519669
},
"updateSource": {
"string": "OCEAN"
}
}

Note:

  1. There will be no G2C for the V4 Topic.
  2. V3 includes only ocean facilities, while V4 consolidates all facilities (LnS, Ocean, Commercial).
SchemaLinkSample FeedStatusV3 Topic NameV4 Topic NameSample DataRemarks
Facility AVRO SchemaAPI-JSON-Schema-Definitions/models/900-SMDS/v2/preprod/Facility.v2.avsc at 218cbacda4b2d4162bebc978e38b0d10720c4022 · Maersk-Global/API-JSON-Schema-Definitions (github.com)Approved by MIM teamSIT: MSK.geography.facility.topic.internal.any.v3 PP/PROD: MSK.geography.facility.topic.internal.any.v3SIT: msk.geography.test.facility.topic.internal.any.v4 PP/PROD: MSK.geography.facility.topic.internal.any.v4

Facility Consumer Owner Information:

Application NameConsume TypeSPOCPROD StatusConsumer Expected Release Date
cometFrom Cloudharshada.shirke@maersk.comanupam.kharade@maersk.comashish.dwivedi@maersk.comrohit.patil@maersk.comPre Prod TestingRelease Expected in Q1 2022
dnetaceFrom Cloudadan.barea@maersk.comcelia.moreno@maersk.comProduction
globeFrom Clouddaniel.dollinger-external@hamburgsud.comPhilipp.Marschall-External@hamburgsud.comRadoslaw.Zukowski-External@hamburgsud.comMariusz.Luttera-External@hamburgsud.comSimon.Werner@hamburgsud.comrajesh.jena-External@hamburgsud.comPre Prod TestingRelease Expected in Q2 2022
ohmFrom Cloudsrikanth.srinivasa@maersk.comkirankumar.talawai@maersk.comProduction
public-trackingFrom Clouddiogo.amorim@maersk.comanders.clausen1@maersk.comricardo.passos@maersk.comabhilash.pulluri@maersk.comProduction
rockFrom Cloudahmar.husain@maersk.comvimal.sivasubramanian@maersk.comdimitar.dimitrov@maersk.compawan.kumar.regoti@maersk.comProduction
starconnectFrom Cloudandy.william.yu.yeh@maersk.comsergio.durand@maersk.comProduction
traxensFrom Cloudpriyanka.chawla@maersk.commukesh.dab@maersk.comProduction
flow-plannerFrom Cloudhossein.zahed@maersk.comnurefsan.gur@maersk.comshahid.aman@maersk.comjazeem.azeez@maersk.combence.hajdu@maersk.comProduction
dnetdataFrom Cloudharry.huang@maersk.comronaq.taneja@maersk.comshekhar.daima@maersk.comrussell.baker@maersk.comsunny.jain@maersk.comPre Prod Testing
synergy-reference-dataFrom Clouddiogo.amorim@maersk.comanders.clausen1@maersk.comricardo.passos@maersk.comflaviu.muresan@maersk.comabhilash.pulluri@maersk.comPre Prod Testing
dnet-dsmFrom Cloudsevak.mnatsakanyan@maersk.combehzad.alamdari@maersk.comfabricio.bastian@maersk.comgheorghita-amalia.caldare@maersk.comlasse.duer@maersk.comsumit.s@maersk.comPre Prod Testing
Decision platformFrom cloudlohith.huchaveerachar@lns.maersk.com, Eileen.Refran@Maersk.com
SEEBURGERFrom cloudbadhrish.srinivas@lns.maersk.comheather.rutkowski@lns.maersk.comProd
AIR LCLFrom Cloudbenny.zhang@maersk.com, jack.peng@maersk.comProdAdded on 24 Nov 2022
CUSFrom Cloudmikael.kuhn@maersk.comjonas.lomholdt@maersk.comkristoffer.petersen@maersk.comangela.patino.yuli@maersk.comkristian.dam-bori@maersk.commilad.ahmadi.ghomrodi@maersk.comnur.azad@maersk.comPre Prod TestingAdded on 8th Nov 2023
ATHENAFrom cloudProd

Facility Configuration Details:

Topic NameMessage FormatGeo Avro SchemaMessage HeaderKey Columns to Get Geo DataSample MessageProducer TriggerPre-Prod Sample Producer Parameter
MSK.geography.facility.topic.internal.any.v3JSONOpsFacility_AvroSchema.avsc The message we are sending will be validated against the Avro schema. Please refer to the attached Avro schema for Facility. Note: GeoSite will publish to the Facility Topic.When producing a message, we append the following audit details: EventType EventDescription EventDateTime MessageId **Sample Data for Header Fields:**EventType: Create/Update EventDescription: vesselCreated / vesselDataUpdated EventDateTime: Wed Feb 13 09:46:36 UTC 2021 MessageId: 93f0d94f-c1a9-4d33-8f6c-92cf88f54846Facility Rowid While producing a message to EMP, we pass FacilityRowid to the service, fetching data based on that and converting it into a JSON object.CommercialFacility.json OperationalFacility.json CustomerFacility.jsonSMDS Facility applicationkafka.topic: MSK.geography.facility.topic.internal.any.v3 kafka.bootstrap-servers: rp-cde-rpx-stage.crb.apmoller.net:9093 kafka.username: <Emp Team Provided User Name &gt; kafka.password: <Emp Team Provided Password &gt; kafka.schema-registry-url: https://lb-sre-stage-cde.crb.apmoller.net:8081kafka.sasl.jaas.config: org.apache.kafka.common.security.scram.ScramLoginModule required username="<Emp Team Provided User Name>" password="<Emp Team Provided Password>"; kafka.ssl.truststore-location: <trust store file location path &gt; kafka.ssl.truststore-password: <trust store password &gt; kafka.schema-registry-ssl-protocol: TLS kafka.onprem-sasl-mechanism: SCRAM-SHA-256 kafka.ssl.keystore-location: <key store file location path &gt; kafka.ssl.keystore-password: <key store password &gt; key-password: <key store password &gt; kafka.onprem-login-module: org.apache.kafka.common.security.scram.ScramLoginModule **Topic Level Configuration:**ccloud_Retention Period: 72 Hrs ccloud_cleanup_policy: compact compact Mode: ON, which allows the latest message to survive in the topic based on the defined retention period. topic_type: avro replication_flow: g2c Log Compaction is enabled based on the facility ID (Geo ID).
Was this page helpful?