Publishing Simple EagleML Extract Results to a Kafka Topic

Example of RTR

<EagleML xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:type="RunTaskRequestSync" eaglemlType="RunTaskRequest" eaglemlVersion="2.0">
  <header>
    <messageId>ID:EXTRACT</messageId>
    <sentBy>http://www.client.com</sentBy>
    <sendTo>http://www.eagleinvsys.com/eagle_ml-2-0_default_out_extract_service</sendTo>
    <replyTo>http://www.client.com/Eagle Control Messages</replyTo>
  </header>
  <taskIdentifier>
    <correlationId>MC2_ENTITY_XML_NUG_{GUID}</correlationId>
    <businessTaskId>YIELDCURVEEXTRACT</businessTaskId>
  </taskIdentifier>
  <taskTypeEnum>LOAD</taskTypeEnum>
  <synchronousExecution>no</synchronousExecution>
  <taskParameters>
    <taskParameter>
      <name>ActionType</name>
      <value>EXTRACT</value>
    </taskParameter>
    <taskParameter>
      <name>FeedType</name>
      <value>ENTITYEXTRACT</value>
    </taskParameter>
    <taskParameter>
      <name>maxrows</name>
      <value>10</value>
    </taskParameter>
    <taskParameter>
      <name>RecordCountPerNugget</name>
      <value>2</value>
    </taskParameter>
    <taskParameter>
        <name>ExtractDeliveryMethod</name>
        <dataType>S</dataType>
        <value>MESSAGE</value>
    </taskParameter>  
    <taskParameter>
        <name>ReplyDeliveryMethod</name>
        <dataType>S</dataType>
        <value>MESSAGE</value>
    </taskParameter>
    <taskParameter>
        <name>EnableReplyDelivery</name>
        <dataType>S</dataType>
        <value>Y</value>
    </taskParameter>  
    <taskParameter>
        <name>MessagingExtractDeliveryURI</name>
        <dataType>S</dataType>
        <value>kafkamessaging:kafkaExtractProducer</value>
    </taskParameter>
    <taskParameter>
        <name>MessagingReplyDeliveryURI</name>
        <dataType>S</dataType>
        <value>kafkamessaging:kafkaReplyProducer</value>
    </taskParameter>  
  </taskParameters>
</EagleML>

Reply by REST

<EagleML eaglemlVersion="2-0"
            eaglemlType="TaskStatusResponse"
            xsi:schemaLocation="http://www.eagleinvsys.com/2011/EagleML-2-0 eagleml-main-2-0.xsd"
            xsi:type="TaskStatusResponse"
            xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
            xmlns="http://www.eagleinvsys.com/2011/EagleML-2-0">
<header>
<messageId>G4ISE97BYW4FLJE5</messageId>
<inReplyTo>http://www.client.com/Eagle Control Messages</inReplyTo>
<sentBy>http://www.eagleinvsys.com/</sentBy>
<creationTimestamp>2020-06-09T15:08:08-04:00</creationTimestamp>
</header>
<statusItem>
<taskIdentifier>
<correlationId correlationIdScheme="correlationIdScheme">MC2_ENTITY_XML_NUG_AIM1WPFCIMHO00P13</correlationId>
<businessTaskId businessTaskIdScheme="businessTaskIdScheme">YIELDCURVEEXTRACT</businessTaskId>
</taskIdentifier>
<status>SUCCESS</status>
<severityCode>0</severityCode>
<extractFilename>MC2_ENTITY_XML_NUG_AIM1WPFCIMHO00P13_ENTITYEXTRACT_1_MORE_2_20200609.xml</extractFilename>
<extractFilename>MC2_ENTITY_XML_NUG_AIM1WPFCIMHO00P13_ENTITYEXTRACT_2_MORE_2_20200609.xml</extractFilename>
<extractFilename>MC2_ENTITY_XML_NUG_AIM1WPFCIMHO00P13_ENTITYEXTRACT_3_MORE_2_20200609.xml</extractFilename>
<extractFilename>MC2_ENTITY_XML_NUG_AIM1WPFCIMHO00P13_ENTITYEXTRACT_4_MORE_2_20200609.xml</extractFilename>
<extractFilename>MC2_ENTITY_XML_NUG_AIM1WPFCIMHO00P13_ENTITYEXTRACT_5_LAST_2_20200609.xml</extractFilename>
<objectCount>10</objectCount>
<reason>
<reasonTypeEnum>INFO</reasonTypeEnum>
<reasonCode>NuggetCount</reasonCode>
<description>5</description>
</reason>
</statusItem>
</EagleML>

Results written on disk by mc2kafka consumers (mc2_kafka_messaging_(3)__15:08:08.632.xml - with reply content):

MCC