Configuring Send Event Task with Kafka

Flowable Engine
1

I was able to receive messages/events from Kafka to for example start processes, but I can’t seem to send a message/event to Kafka channel. Please help thanks in advance.

Flowable version 6.7.2, Spring boot version 2.6.11

.channel file:

{
  "type": "kafka",
  "channelType": "outbound",
  "serializerType": "json",
  "topic": "usersentiment",
  "name": "Send Channel",
  "key": "sendChannel"
}

.event file:

{
  "correlationParameters": [],
  "payload": [
    {
      "name": "id",
      "type": "string"
    },
    {
      "name": "messageString",
      "type": "string"
    }
  ],
  "name": "Send Outbound Event",
  "key": "sendEvent",
  "outboundChannelKeys": [
    "sendChannel"
  ]
}

event-registry-test.bpmn20.xml:

<?xml version="1.0" encoding="UTF-8"?>
<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:flowable="http://flowable.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://flowable.org/test" exporter="Flowable Open Source Modeler" exporterVersion="6.7.2">
  <collaboration id="Collaboration">
    <participant id="sid-98C01244-9955-4AD0-872E-C96535614BA0" processRef="print-message-process"></participant>
    <participant id="sid-60625F43-588B-4DEC-8EA4-5B1555D36063" processRef="processA"></participant>
    <participant id="sid-7F69A130-52A1-42A1-B951-850435FF3F3C" processRef="processB"></participant>
    <participant id="sid-F0A65E80-8CFB-436D-94ED-6C4A81162A67" processRef="processC"></participant>
    <participant id="sid-86802B82-6D34-466A-B88D-CBFEF65FD607" processRef="print-process"></participant>
  </collaboration>
  <process id="print-message-process" isExecutable="true">
    <laneSet id="laneSet_print-message-process">
      <lane id="sid-A849AE4D-FEAE-4206-A380-6E7CE9F18B70">
        <flowNodeRef>sid-5C82066E-7249-453E-9CBC-76B2B473737C</flowNodeRef>
        <flowNodeRef>sid-EA494547-8DF1-4BB0-8850-578E13614085</flowNodeRef>
        <flowNodeRef>sid-7FAB80EA-06CB-4A7E-9E0C-DC08F123CD84</flowNodeRef>
        <flowNodeRef>sid-CD25420C-FFC6-469E-9786-9E9D1DEE9A0A</flowNodeRef>
        <flowNodeRef>sid-7C73D093-7308-450F-8989-D40C662B3045</flowNodeRef>
        <flowNodeRef>sid-FE981518-7767-48A0-97AB-DF3CB0863A66</flowNodeRef>
        <flowNodeRef>sid-7935775F-17AC-4C52-BF69-30FB986FA66B</flowNodeRef>
      </lane>
    </laneSet>
    <startEvent id="sid-5C82066E-7249-453E-9CBC-76B2B473737C">
      <extensionElements>
        <flowable:eventType xmlns:flowable="http://flowable.org/bpmn"><![CDATA[emotionEvent]]></flowable:eventType>
        <flowable:eventName xmlns:flowable="http://flowable.org/bpmn"><![CDATA[Emotion Event]]></flowable:eventName>
        <flowable:eventOutParameter xmlns:flowable="http://flowable.org/bpmn" source="id" sourceType="string" target="id"></flowable:eventOutParameter>
        <flowable:eventOutParameter xmlns:flowable="http://flowable.org/bpmn" source="messageString" sourceType="string" target="messageString"></flowable:eventOutParameter>
        <flowable:channelKey xmlns:flowable="http://flowable.org/bpmn"><![CDATA[sentimentAnalysisInboundChannel]]></flowable:channelKey>
        <flowable:channelName xmlns:flowable="http://flowable.org/bpmn"><![CDATA[Sentiment Analysis Inbound Channel]]></flowable:channelName>
        <flowable:channelType xmlns:flowable="http://flowable.org/bpmn"><![CDATA[kafka]]></flowable:channelType>
      </extensionElements>
    </startEvent>
    <serviceTask id="sid-EA494547-8DF1-4BB0-8850-578E13614085" name="Print" flowable:class="com.brighthope.processengine.servicetask.PrintDelegate"></serviceTask>
    <scriptTask id="sid-7FAB80EA-06CB-4A7E-9E0C-DC08F123CD84" name="print id and message" flowable:autoStoreVariables="false">
      <script><![CDATA[${printService.print(id)}
${printService.print(messageString)}]]></script>
    </scriptTask>
    <endEvent id="sid-CD25420C-FFC6-469E-9786-9E9D1DEE9A0A"></endEvent>
    <sequenceFlow id="sid-7C73D093-7308-450F-8989-D40C662B3045" sourceRef="sid-5C82066E-7249-453E-9CBC-76B2B473737C" targetRef="sid-EA494547-8DF1-4BB0-8850-578E13614085"></sequenceFlow>
    <sequenceFlow id="sid-FE981518-7767-48A0-97AB-DF3CB0863A66" sourceRef="sid-EA494547-8DF1-4BB0-8850-578E13614085" targetRef="sid-7FAB80EA-06CB-4A7E-9E0C-DC08F123CD84"></sequenceFlow>
    <sequenceFlow id="sid-7935775F-17AC-4C52-BF69-30FB986FA66B" sourceRef="sid-7FAB80EA-06CB-4A7E-9E0C-DC08F123CD84" targetRef="sid-CD25420C-FFC6-469E-9786-9E9D1DEE9A0A"></sequenceFlow>
  </process>
  <process id="processA" isExecutable="true">
    <laneSet id="laneSet_processA">
      <lane id="sid-32C81EEA-86AD-4429-9646-B13B82683721">
        <flowNodeRef>sid-BAAEF126-F0B1-4D71-9B5F-5B478C093322</flowNodeRef>
        <flowNodeRef>sid-D1A281B2-3419-46ED-A1BA-F9498B221D45</flowNodeRef>
        <flowNodeRef>sid-91CD910F-A897-4E24-8E0D-DCF02867CEAA</flowNodeRef>
        <flowNodeRef>sid-255537E0-1E91-4B6D-AD8F-DB895B0E57F2</flowNodeRef>
        <flowNodeRef>sid-A564210A-36CB-4C2A-A4D9-CFC4FA23913D</flowNodeRef>
      </lane>
    </laneSet>
    <startEvent id="sid-BAAEF126-F0B1-4D71-9B5F-5B478C093322" flowable:formFieldValidation="true"></startEvent>
    <endEvent id="sid-D1A281B2-3419-46ED-A1BA-F9498B221D45"></endEvent>
    <serviceTask id="sid-91CD910F-A897-4E24-8E0D-DCF02867CEAA" name="Send Event" flowable:type="send-event">
      <extensionElements>
        <flowable:eventType><![CDATA[sendEvent]]></flowable:eventType>
        <flowable:eventInParameter sourceExpression="${id}" target="id" targetType="string"></flowable:eventInParameter>
        <flowable:eventInParameter sourceExpression="${messageString}" target="messageString" targetType="string"></flowable:eventInParameter>
        <flowable:channelKey xmlns:flowable="http://flowable.org/bpmn"><![CDATA[sendChannel]]></flowable:channelKey>
      </extensionElements>
    </serviceTask>
    <sequenceFlow id="sid-255537E0-1E91-4B6D-AD8F-DB895B0E57F2" sourceRef="sid-BAAEF126-F0B1-4D71-9B5F-5B478C093322" targetRef="sid-91CD910F-A897-4E24-8E0D-DCF02867CEAA"></sequenceFlow>
    <sequenceFlow id="sid-A564210A-36CB-4C2A-A4D9-CFC4FA23913D" sourceRef="sid-91CD910F-A897-4E24-8E0D-DCF02867CEAA" targetRef="sid-D1A281B2-3419-46ED-A1BA-F9498B221D45"></sequenceFlow>
  </process>
  <process id="processB" isExecutable="true">
    <laneSet id="laneSet_processB">
      <lane id="sid-51220DD5-0D60-4809-A46B-AAFE5DC3DAFA">
        <flowNodeRef>sid-2D769C09-A285-4B78-9AD0-036324A01EBB</flowNodeRef>
        <flowNodeRef>sid-9B8A0098-81A5-4CB3-B462-2A5796E60201</flowNodeRef>
        <flowNodeRef>sid-BB947645-1704-4499-9AC2-B7E20F8A2006</flowNodeRef>
        <flowNodeRef>sid-5A53D7FA-58C6-438C-A83F-623E65E88F05</flowNodeRef>
        <flowNodeRef>sid-CB0A1E09-09CE-4FC4-9C37-A35C24E7666F</flowNodeRef>
        <flowNodeRef>sid-4C40DBE1-FB27-4CEA-AAD2-7FB758868567</flowNodeRef>
        <flowNodeRef>sid-86CD8111-9377-4361-8354-68BB96426913</flowNodeRef>
      </lane>
    </laneSet>
    <startEvent id="sid-2D769C09-A285-4B78-9AD0-036324A01EBB" flowable:formFieldValidation="true"></startEvent>
    <endEvent id="sid-9B8A0098-81A5-4CB3-B462-2A5796E60201"></endEvent>
    <serviceTask id="sid-BB947645-1704-4499-9AC2-B7E20F8A2006" name="Send Event" flowable:type="send-event">
      <extensionElements>
        <flowable:eventType><![CDATA[sendEvent]]></flowable:eventType>
        <flowable:eventInParameter sourceExpression="${id}" target="id" targetType="string"></flowable:eventInParameter>
        <flowable:eventInParameter sourceExpression="${messageString}" target="messageString" targetType="string"></flowable:eventInParameter>
        <flowable:channelKey xmlns:flowable="http://flowable.org/bpmn"><![CDATA[sendChannel]]></flowable:channelKey>
        <flowable:channelType xmlns:flowable="http://flowable.org/bpmn"><![CDATA[kafka]]></flowable:channelType>
      </extensionElements>
    </serviceTask>
    <scriptTask id="sid-5A53D7FA-58C6-438C-A83F-623E65E88F05" name="Send Task B" scriptFormat="javascript" flowable:autoStoreVariables="false">
      <script><![CDATA[execution.setVariable('id', 'B');
execution.setVariable('messageString', 'Hello World, This is Process  B');]]></script>
    </scriptTask>
    <sequenceFlow id="sid-CB0A1E09-09CE-4FC4-9C37-A35C24E7666F" sourceRef="sid-2D769C09-A285-4B78-9AD0-036324A01EBB" targetRef="sid-5A53D7FA-58C6-438C-A83F-623E65E88F05"></sequenceFlow>
    <sequenceFlow id="sid-4C40DBE1-FB27-4CEA-AAD2-7FB758868567" sourceRef="sid-5A53D7FA-58C6-438C-A83F-623E65E88F05" targetRef="sid-BB947645-1704-4499-9AC2-B7E20F8A2006"></sequenceFlow>
    <sequenceFlow id="sid-86CD8111-9377-4361-8354-68BB96426913" sourceRef="sid-BB947645-1704-4499-9AC2-B7E20F8A2006" targetRef="sid-9B8A0098-81A5-4CB3-B462-2A5796E60201"></sequenceFlow>
  </process>
  <process id="processC" isExecutable="true">
    <laneSet id="laneSet_processC">
      <lane id="sid-F274AF28-66F6-48B1-AA1B-CDD63D4A0948">
        <flowNodeRef>sid-80F0E6E5-5583-487D-9E18-FF26F471CA1A</flowNodeRef>
        <flowNodeRef>sid-09CC4E4C-5599-4EFD-824A-0A7EC8AAC8AA</flowNodeRef>
        <flowNodeRef>sid-E4C5CBB9-F0E9-4314-A616-71F89F927229</flowNodeRef>
        <flowNodeRef>sid-D3821C3E-2608-46DF-9DB1-F1E20D3F8E91</flowNodeRef>
        <flowNodeRef>sid-55C0ED96-F51B-46FE-8854-8E9FE65715A6</flowNodeRef>
        <flowNodeRef>sid-2928A67E-6B2F-48C2-9EE6-39E73F622874</flowNodeRef>
        <flowNodeRef>sid-2DD3CD83-5912-4548-BECC-C67669A4C905</flowNodeRef>
      </lane>
    </laneSet>
    <startEvent id="sid-80F0E6E5-5583-487D-9E18-FF26F471CA1A" flowable:formFieldValidation="true"></startEvent>
    <endEvent id="sid-09CC4E4C-5599-4EFD-824A-0A7EC8AAC8AA"></endEvent>
    <serviceTask id="sid-E4C5CBB9-F0E9-4314-A616-71F89F927229" name="Send Event" flowable:type="send-event">
      <extensionElements>
        <flowable:eventType><![CDATA[sendEvent]]></flowable:eventType>
        <flowable:eventInParameter sourceExpression="${id}" target="id" targetType="string"></flowable:eventInParameter>
        <flowable:eventInParameter sourceExpression="${messageString}" target="messageString" targetType="string"></flowable:eventInParameter>
        <flowable:channelKey xmlns:flowable="http://flowable.org/bpmn"><![CDATA[sendChannel]]></flowable:channelKey>
        <flowable:channelType xmlns:flowable="http://flowable.org/bpmn"><![CDATA[kafka]]></flowable:channelType>
      </extensionElements>
    </serviceTask>
    <scriptTask id="sid-D3821C3E-2608-46DF-9DB1-F1E20D3F8E91" name="Send Task C" scriptFormat="javascript" flowable:autoStoreVariables="false">
      <script><![CDATA[execution.setVariable('id', 'C');
execution.setVariable('messageString', 'Hello World, This is Process  C');]]></script>
    </scriptTask>
    <sequenceFlow id="sid-55C0ED96-F51B-46FE-8854-8E9FE65715A6" sourceRef="sid-80F0E6E5-5583-487D-9E18-FF26F471CA1A" targetRef="sid-D3821C3E-2608-46DF-9DB1-F1E20D3F8E91"></sequenceFlow>
    <sequenceFlow id="sid-2928A67E-6B2F-48C2-9EE6-39E73F622874" sourceRef="sid-D3821C3E-2608-46DF-9DB1-F1E20D3F8E91" targetRef="sid-E4C5CBB9-F0E9-4314-A616-71F89F927229"></sequenceFlow>
    <sequenceFlow id="sid-2DD3CD83-5912-4548-BECC-C67669A4C905" sourceRef="sid-E4C5CBB9-F0E9-4314-A616-71F89F927229" targetRef="sid-09CC4E4C-5599-4EFD-824A-0A7EC8AAC8AA"></sequenceFlow>
  </process>
  <process id="print-process" isExecutable="true">
    <laneSet id="laneSet_print-process">
      <lane id="sid-B456B62D-1B99-4FB3-B83D-DD67F25EED03">
        <flowNodeRef>sid-118DEDFD-6EC5-4691-93A2-0C6A75DFE013</flowNodeRef>
        <flowNodeRef>sid-FAA3F95A-1576-4AC8-97C1-747D69863C74</flowNodeRef>
        <flowNodeRef>sid-C6F6E6BA-907A-4C83-940D-5C3EFF03BEB8</flowNodeRef>
        <flowNodeRef>sid-4FB12DFB-7092-4A85-BB42-46F8E31B0DD4</flowNodeRef>
        <flowNodeRef>sid-0B5BDFB4-5196-4D87-ACCE-BFBCAE39A26E</flowNodeRef>
      </lane>
    </laneSet>
    <startEvent id="sid-118DEDFD-6EC5-4691-93A2-0C6A75DFE013">
      <extensionElements>
        <flowable:eventType xmlns:flowable="http://flowable.org/bpmn"><![CDATA[emotionEvent]]></flowable:eventType>
        <flowable:eventName xmlns:flowable="http://flowable.org/bpmn"><![CDATA[Emotion Event]]></flowable:eventName>
        <flowable:eventOutParameter xmlns:flowable="http://flowable.org/bpmn" source="id" sourceType="string" target="id"></flowable:eventOutParameter>
        <flowable:eventOutParameter xmlns:flowable="http://flowable.org/bpmn" source="messageString" sourceType="string" target="messageString"></flowable:eventOutParameter>
        <flowable:channelKey xmlns:flowable="http://flowable.org/bpmn"><![CDATA[sentimentAnalysisInboundChannel]]></flowable:channelKey>
        <flowable:channelName xmlns:flowable="http://flowable.org/bpmn"><![CDATA[Sentiment Analysis Inbound Channel]]></flowable:channelName>
        <flowable:channelType xmlns:flowable="http://flowable.org/bpmn"><![CDATA[kafka]]></flowable:channelType>
      </extensionElements>
    </startEvent>
    <scriptTask id="sid-FAA3F95A-1576-4AC8-97C1-747D69863C74" name="print duar duar" flowable:autoStoreVariables="false">
      <script><![CDATA[${printService.print("duar duar duar")}]]></script>
    </scriptTask>
    <endEvent id="sid-C6F6E6BA-907A-4C83-940D-5C3EFF03BEB8"></endEvent>
    <sequenceFlow id="sid-4FB12DFB-7092-4A85-BB42-46F8E31B0DD4" sourceRef="sid-118DEDFD-6EC5-4691-93A2-0C6A75DFE013" targetRef="sid-FAA3F95A-1576-4AC8-97C1-747D69863C74"></sequenceFlow>
    <sequenceFlow id="sid-0B5BDFB4-5196-4D87-ACCE-BFBCAE39A26E" sourceRef="sid-FAA3F95A-1576-4AC8-97C1-747D69863C74" targetRef="sid-C6F6E6BA-907A-4C83-940D-5C3EFF03BEB8"></sequenceFlow>
  </process>
  <bpmndi:BPMNDiagram id="BPMNDiagram_Collaboration">
    <bpmndi:BPMNPlane bpmnElement="Collaboration" id="BPMNPlane_Collaboration">
      <bpmndi:BPMNShape bpmnElement="sid-98C01244-9955-4AD0-872E-C96535614BA0" id="BPMNShape_sid-98C01244-9955-4AD0-872E-C96535614BA0">
        <omgdc:Bounds height="250.0" width="600.0" x="80.5" y="1039.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-A849AE4D-FEAE-4206-A380-6E7CE9F18B70" id="BPMNShape_sid-A849AE4D-FEAE-4206-A380-6E7CE9F18B70">
        <omgdc:Bounds height="250.0" width="570.0" x="110.5" y="1039.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-5C82066E-7249-453E-9CBC-76B2B473737C" id="BPMNShape_sid-5C82066E-7249-453E-9CBC-76B2B473737C">
        <omgdc:Bounds height="30.0" width="30.5" x="163.875" y="1149.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-EA494547-8DF1-4BB0-8850-578E13614085" id="BPMNShape_sid-EA494547-8DF1-4BB0-8850-578E13614085">
        <omgdc:Bounds height="80.0" width="100.0" x="239.375" y="1124.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-7FAB80EA-06CB-4A7E-9E0C-DC08F123CD84" id="BPMNShape_sid-7FAB80EA-06CB-4A7E-9E0C-DC08F123CD84">
        <omgdc:Bounds height="80.0" width="100.0" x="424.125" y="1124.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-CD25420C-FFC6-469E-9786-9E9D1DEE9A0A" id="BPMNShape_sid-CD25420C-FFC6-469E-9786-9E9D1DEE9A0A">
        <omgdc:Bounds height="28.0" width="28.0" x="569.125" y="1150.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-60625F43-588B-4DEC-8EA4-5B1555D36063" id="BPMNShape_sid-60625F43-588B-4DEC-8EA4-5B1555D36063">
        <omgdc:Bounds height="250.0" width="600.0" x="80.5" y="90.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-32C81EEA-86AD-4429-9646-B13B82683721" id="BPMNShape_sid-32C81EEA-86AD-4429-9646-B13B82683721">
        <omgdc:Bounds height="250.0" width="570.0" x="110.5" y="90.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-BAAEF126-F0B1-4D71-9B5F-5B478C093322" id="BPMNShape_sid-BAAEF126-F0B1-4D71-9B5F-5B478C093322">
        <omgdc:Bounds height="30.0" width="30.0" x="176.5" y="183.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-D1A281B2-3419-46ED-A1BA-F9498B221D45" id="BPMNShape_sid-D1A281B2-3419-46ED-A1BA-F9498B221D45">
        <omgdc:Bounds height="28.0" width="28.0" x="541.5" y="184.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-91CD910F-A897-4E24-8E0D-DCF02867CEAA" id="BPMNShape_sid-91CD910F-A897-4E24-8E0D-DCF02867CEAA">
        <omgdc:Bounds height="80.0" width="100.0" x="396.5" y="158.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-7F69A130-52A1-42A1-B951-850435FF3F3C" id="BPMNShape_sid-7F69A130-52A1-42A1-B951-850435FF3F3C">
        <omgdc:Bounds height="250.0" width="600.0" x="80.5" y="360.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-51220DD5-0D60-4809-A46B-AAFE5DC3DAFA" id="BPMNShape_sid-51220DD5-0D60-4809-A46B-AAFE5DC3DAFA">
        <omgdc:Bounds height="250.0" width="570.0" x="110.5" y="360.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-2D769C09-A285-4B78-9AD0-036324A01EBB" id="BPMNShape_sid-2D769C09-A285-4B78-9AD0-036324A01EBB">
        <omgdc:Bounds height="30.0" width="30.0" x="176.5" y="453.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-9B8A0098-81A5-4CB3-B462-2A5796E60201" id="BPMNShape_sid-9B8A0098-81A5-4CB3-B462-2A5796E60201">
        <omgdc:Bounds height="28.0" width="28.0" x="541.5" y="454.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-BB947645-1704-4499-9AC2-B7E20F8A2006" id="BPMNShape_sid-BB947645-1704-4499-9AC2-B7E20F8A2006">
        <omgdc:Bounds height="80.0" width="100.0" x="396.5" y="428.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-5A53D7FA-58C6-438C-A83F-623E65E88F05" id="BPMNShape_sid-5A53D7FA-58C6-438C-A83F-623E65E88F05">
        <omgdc:Bounds height="80.0" width="100.0" x="251.5" y="428.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-F0A65E80-8CFB-436D-94ED-6C4A81162A67" id="BPMNShape_sid-F0A65E80-8CFB-436D-94ED-6C4A81162A67">
        <omgdc:Bounds height="250.0" width="600.0" x="80.5" y="630.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-F274AF28-66F6-48B1-AA1B-CDD63D4A0948" id="BPMNShape_sid-F274AF28-66F6-48B1-AA1B-CDD63D4A0948">
        <omgdc:Bounds height="250.0" width="570.0" x="110.5" y="630.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-80F0E6E5-5583-487D-9E18-FF26F471CA1A" id="BPMNShape_sid-80F0E6E5-5583-487D-9E18-FF26F471CA1A">
        <omgdc:Bounds height="30.0" width="30.0" x="176.5" y="723.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-09CC4E4C-5599-4EFD-824A-0A7EC8AAC8AA" id="BPMNShape_sid-09CC4E4C-5599-4EFD-824A-0A7EC8AAC8AA">
        <omgdc:Bounds height="28.0" width="28.0" x="541.5" y="724.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-E4C5CBB9-F0E9-4314-A616-71F89F927229" id="BPMNShape_sid-E4C5CBB9-F0E9-4314-A616-71F89F927229">
        <omgdc:Bounds height="80.0" width="100.0" x="396.5" y="698.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-D3821C3E-2608-46DF-9DB1-F1E20D3F8E91" id="BPMNShape_sid-D3821C3E-2608-46DF-9DB1-F1E20D3F8E91">
        <omgdc:Bounds height="80.0" width="100.0" x="251.5" y="698.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-86802B82-6D34-466A-B88D-CBFEF65FD607" id="BPMNShape_sid-86802B82-6D34-466A-B88D-CBFEF65FD607">
        <omgdc:Bounds height="250.0" width="600.0" x="80.5" y="1329.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-B456B62D-1B99-4FB3-B83D-DD67F25EED03" id="BPMNShape_sid-B456B62D-1B99-4FB3-B83D-DD67F25EED03">
        <omgdc:Bounds height="250.0" width="570.0" x="110.5" y="1329.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-118DEDFD-6EC5-4691-93A2-0C6A75DFE013" id="BPMNShape_sid-118DEDFD-6EC5-4691-93A2-0C6A75DFE013">
        <omgdc:Bounds height="30.0" width="30.5" x="163.875" y="1439.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-FAA3F95A-1576-4AC8-97C1-747D69863C74" id="BPMNShape_sid-FAA3F95A-1576-4AC8-97C1-747D69863C74">
        <omgdc:Bounds height="80.0" width="100.0" x="344.125" y="1414.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="sid-C6F6E6BA-907A-4C83-940D-5C3EFF03BEB8" id="BPMNShape_sid-C6F6E6BA-907A-4C83-940D-5C3EFF03BEB8">
        <omgdc:Bounds height="28.0" width="28.0" x="569.125" y="1440.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNEdge bpmnElement="sid-255537E0-1E91-4B6D-AD8F-DB895B0E57F2" id="BPMNEdge_sid-255537E0-1E91-4B6D-AD8F-DB895B0E57F2" flowable:sourceDockerX="15.0" flowable:sourceDockerY="15.0" flowable:targetDockerX="50.0" flowable:targetDockerY="40.0">
        <omgdi:waypoint x="206.4499997188597" y="198.0"></omgdi:waypoint>
        <omgdi:waypoint x="396.5" y="198.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="sid-4FB12DFB-7092-4A85-BB42-46F8E31B0DD4" id="BPMNEdge_sid-4FB12DFB-7092-4A85-BB42-46F8E31B0DD4" flowable:sourceDockerX="15.5" flowable:sourceDockerY="15.0" flowable:targetDockerX="50.0" flowable:targetDockerY="40.0">
        <omgdi:waypoint x="194.82499956251183" y="1454.0"></omgdi:waypoint>
        <omgdi:waypoint x="344.125" y="1454.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="sid-55C0ED96-F51B-46FE-8854-8E9FE65715A6" id="BPMNEdge_sid-55C0ED96-F51B-46FE-8854-8E9FE65715A6" flowable:sourceDockerX="15.0" flowable:sourceDockerY="15.0" flowable:targetDockerX="50.0" flowable:targetDockerY="40.0">
        <omgdi:waypoint x="206.44999848995764" y="738.0"></omgdi:waypoint>
        <omgdi:waypoint x="251.5" y="738.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="sid-FE981518-7767-48A0-97AB-DF3CB0863A66" id="BPMNEdge_sid-FE981518-7767-48A0-97AB-DF3CB0863A66" flowable:sourceDockerX="50.0" flowable:sourceDockerY="40.0" flowable:targetDockerX="50.0" flowable:targetDockerY="40.0">
        <omgdi:waypoint x="339.32500000000005" y="1164.0"></omgdi:waypoint>
        <omgdi:waypoint x="424.12499999984243" y="1164.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="sid-2928A67E-6B2F-48C2-9EE6-39E73F622874" id="BPMNEdge_sid-2928A67E-6B2F-48C2-9EE6-39E73F622874" flowable:sourceDockerX="50.0" flowable:sourceDockerY="40.0" flowable:targetDockerX="50.0" flowable:targetDockerY="40.0">
        <omgdi:waypoint x="351.45000000000005" y="738.0"></omgdi:waypoint>
        <omgdi:waypoint x="396.5" y="738.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="sid-A564210A-36CB-4C2A-A4D9-CFC4FA23913D" id="BPMNEdge_sid-A564210A-36CB-4C2A-A4D9-CFC4FA23913D" flowable:sourceDockerX="50.0" flowable:sourceDockerY="40.0" flowable:targetDockerX="14.0" flowable:targetDockerY="14.0">
        <omgdi:waypoint x="496.449999999996" y="198.0"></omgdi:waypoint>
        <omgdi:waypoint x="541.5" y="198.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="sid-7C73D093-7308-450F-8989-D40C662B3045" id="BPMNEdge_sid-7C73D093-7308-450F-8989-D40C662B3045" flowable:sourceDockerX="15.5" flowable:sourceDockerY="15.0" flowable:targetDockerX="50.0" flowable:targetDockerY="40.0">
        <omgdi:waypoint x="194.82499833332568" y="1164.0"></omgdi:waypoint>
        <omgdi:waypoint x="239.3749999998097" y="1164.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="sid-0B5BDFB4-5196-4D87-ACCE-BFBCAE39A26E" id="BPMNEdge_sid-0B5BDFB4-5196-4D87-ACCE-BFBCAE39A26E" flowable:sourceDockerX="50.0" flowable:sourceDockerY="40.0" flowable:targetDockerX="14.0" flowable:targetDockerY="14.0">
        <omgdi:waypoint x="444.07500000000005" y="1454.0"></omgdi:waypoint>
        <omgdi:waypoint x="569.125" y="1454.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="sid-CB0A1E09-09CE-4FC4-9C37-A35C24E7666F" id="BPMNEdge_sid-CB0A1E09-09CE-4FC4-9C37-A35C24E7666F" flowable:sourceDockerX="15.0" flowable:sourceDockerY="15.0" flowable:targetDockerX="50.0" flowable:targetDockerY="40.0">
        <omgdi:waypoint x="206.44999848995764" y="468.0"></omgdi:waypoint>
        <omgdi:waypoint x="251.5" y="468.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="sid-4C40DBE1-FB27-4CEA-AAD2-7FB758868567" id="BPMNEdge_sid-4C40DBE1-FB27-4CEA-AAD2-7FB758868567" flowable:sourceDockerX="50.0" flowable:sourceDockerY="40.0" flowable:targetDockerX="50.0" flowable:targetDockerY="40.0">
        <omgdi:waypoint x="351.45000000000005" y="468.0"></omgdi:waypoint>
        <omgdi:waypoint x="396.5" y="468.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="sid-7935775F-17AC-4C52-BF69-30FB986FA66B" id="BPMNEdge_sid-7935775F-17AC-4C52-BF69-30FB986FA66B" flowable:sourceDockerX="50.0" flowable:sourceDockerY="40.0" flowable:targetDockerX="14.0" flowable:targetDockerY="14.0">
        <omgdi:waypoint x="524.0749999997428" y="1164.0"></omgdi:waypoint>
        <omgdi:waypoint x="569.125" y="1164.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="sid-2DD3CD83-5912-4548-BECC-C67669A4C905" id="BPMNEdge_sid-2DD3CD83-5912-4548-BECC-C67669A4C905" flowable:sourceDockerX="50.0" flowable:sourceDockerY="40.0" flowable:targetDockerX="14.0" flowable:targetDockerY="14.0">
        <omgdi:waypoint x="496.4499999999908" y="738.0"></omgdi:waypoint>
        <omgdi:waypoint x="541.5" y="738.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="sid-86CD8111-9377-4361-8354-68BB96426913" id="BPMNEdge_sid-86CD8111-9377-4361-8354-68BB96426913" flowable:sourceDockerX="50.0" flowable:sourceDockerY="40.0" flowable:targetDockerX="14.0" flowable:targetDockerY="14.0">
        <omgdi:waypoint x="496.45000000000005" y="468.0"></omgdi:waypoint>
        <omgdi:waypoint x="541.5" y="468.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
    </bpmndi:BPMNPlane>
  </bpmndi:BPMNDiagram>
</definitions>

When query-ing the activities of current process instance I get:
Activity Name: Send Event
Activity Type: sendEventServiceTask
End Time: null
Which means it’s stuck on the Send Event Task, but I can’t make anything of it.

Note and TLDR: I can receive messages from Kafka through Start Event Registry Event, but I can’t send messages to Kafka through Send Event Task

2

I’m adding execution listener to the send event task like so:

<flowable:executionListener event="start" expression="${printService.print('send event is starting')}"></flowable:executionListener>
<flowable:executionListener event="end" expression="${printService.print('send event is ending')}"></flowable:executionListener>
<flowable:executionListener event="take" expression="${printService.print('send event is taking')}"></flowable:executionListener>

but only send event is starting is printed. I really don’t know what’s missing.