messagebus probe: kafka: print headers & timestamp properties

Hi IBM Support,

While integrating with new Kafka brokers using messagebus probe, before integration, we do test the kafka broker connection with kcat consumer utilities as shown below. 

kcat_consumer.sh:

$JAVA -cp $CLASSPATH -Dlog4j.configuration=file:./connect-log4j.properties kafka.tools.ConsoleConsumer --consumer.config client.properties --from-beginning --topic ${TOPIC} --bootstrap-server ${HOST_PORT} --property print.headers=true --property print.timestamp=true

We would like to check how to enable below 2 properties in messagebus probe so that to get necessary timestamps.
--property print.headers=true 
--property print.timestamp=true

Below is explanation of each property:

--property print.headers=true 
This is the time stamp that alarm received from NMS to at OSSDL. Enabling this property will print header as below.

nifiMsgTimestamp:1766229500556,uuid:62d0f5f0-c2b1-4811-a310-57a820a2111d


--property print.timestamp=true
This is the time stamp that OSSDL publish the alarm time on to Kafka Topic. Enabling this property will print header as below.

LogAppendTime:1766229501470



Below is sample output from kafka payload after enabling the 2 properties in kcat utilities.

################################
LogAppendTime:1766229501470 nifiMsgTimestamp:1766229500294,uuid:35d55f97-accd-4205-828e-7e70fa67c52d {
"ackState": "",
"ackSystemId": "",
"ackTime": "",
"ackUserId": "",
"additionalText": "GTP-U Path Failure||6150 srcIPAddr=10.230.20.241;dstIPAddr=10.239.17.114;supplAlarmInfo=Transport network identifier: 0 additiona lFaultID=6150 GTPU-1||||",
"alarmChangedTime": "",
"alarmClearedTime": "",
"alarmEscalation": "",
"alarmId": "223719557",
"alarmRaisedTime": "2025-12-20,14:9:7.0,+3:0",
"alarmReportingTime": "",
"alarmType": "COMMUNICATIONS_ALARM",
"backedUpStatus": "",
"clearSystemId": "",
"clearUserId": "",
"managedObjectClass": "PLMN-PLMN/MRBTS-331439/LNBTS-331439/GTPU-1",
"mtosiSpecificAlarmAttributes": "",
"perceivedSeverity": "MAJOR",
"plannedOutageIndication": "",
"potentialRootCauseIndication": "",
"probableCause": "INDETERMINATE",
"proposedRepairActions": "",
"serviceAffecting": "",
"specificProblem": "7107|BASE STATION CONNECTIVITY PROBLEM",
"systemDN": "",
"trendIndication": "",
"extraField1": {
"key": "sysUpTimeInstance",
"value": "134 days, 10:37:36.05"
},
"extraField2": {
"key": "EventType",
"value": "nbiAlarmNewNotification"
},
"extraField3": {
"key": "nbiOptionalInformation",
"value": "NEName=ZYB071_S_ZHe|originalAlarmId=47c63c6e688ab14ee9b8836f3855ca98ca8234d|maintenanceRegion=MR-SRAN|siteObjName=|siteObjDN=|siteObjA ddress=|controlObjName=ZYB071_S_ZHe|controlObjSiteAddress=|controlObjMR=MR-SRAN|alarmCount=1|enrichmentTag=4G,SRAN|originalSeverity=indeterminate|probab leCauseText=Indeterminate|maintenanceRegionDN=MRC-MRC/MR-SRAN"
},
"extraField4": {
"key": "nbiSequenceId",
"value": "62639110"
},
"extraField5": {
"key": "nbiEventTime",
"value": "2025-12-20,14:18:20.1,+3:0"
},
"extraField6": {
"key": "requestID",
"value": "1666242237"
}
}
################################

Best Regards,
Vamsee Sunku