DiagramaUml.svg

<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<svg xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" contentScriptType="application/ecmascript" contentStyleType="text/css" height="901px" preserveAspectRatio="none" style="width:3731px;height:901px;background:#FFFFFF;" version="1.1" viewBox="0 0 3731 901" width="3731px" zoomAndPan="magnify"><defs><filter height="300%" id="f1gtkmahyy9zwr" width="300%" x="-1" y="-1"><feGaussianBlur result="blurOut" stdDeviation="2.0"/><feColorMatrix in="blurOut" result="blurOut2" type="matrix" values="0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 .4 0"/><feOffset dx="4.0" dy="4.0" in="blurOut2" result="blurOut3"/><feBlend in="SourceGraphic" in2="blurOut3" mode="normal"/></filter></defs><g><!--MD5=[6d76b0d35cd3ff26e978a24857ccb8f3]
cluster Commons Module--><polygon fill="#DDDDDD" filter="url(#f1gtkmahyy9zwr)" points="2798,391,2946,391,2953,413.2969,3714,413.2969,3714,546,2798,546,2798,391" style="stroke:#000000;stroke-width:1.5;"/><line style="stroke:#000000;stroke-width:1.5;" x1="2798" x2="2953" y1="413.2969" y2="413.2969"/><text fill="#000000" font-family="sans-serif" font-size="14" font-weight="bold" lengthAdjust="spacing" textLength="142" x="2802" y="405.9951">Commons Module</text><!--MD5=[0b629c2a7e6eb7495a9c3d558d8f4a64]
cluster Producer Module--><polygon fill="#DDDDDD" filter="url(#f1gtkmahyy9zwr)" points="1481,6,1622,6,1629,28.2969,2774,28.2969,2774,734,1481,734,1481,6" style="stroke:#000000;stroke-width:1.5;"/><line style="stroke:#000000;stroke-width:1.5;" x1="1481" x2="1629" y1="28.2969" y2="28.2969"/><text fill="#000000" font-family="sans-serif" font-size="14" font-weight="bold" lengthAdjust="spacing" textLength="135" x="1485" y="20.9951">Producer Module</text><!--MD5=[69a90bcd5803e1f083d2c62f0fe9a55d]
cluster Consumer Module--><polygon fill="#DDDDDD" filter="url(#f1gtkmahyy9zwr)" points="16,342,165,342,172,364.2969,1457,364.2969,1457,894,16,894,16,342" style="stroke:#000000;stroke-width:1.5;"/><line style="stroke:#000000;stroke-width:1.5;" x1="16" x2="172" y1="364.2969" y2="364.2969"/><text fill="#000000" font-family="sans-serif" font-size="14" font-weight="bold" lengthAdjust="spacing" textLength="143" x="20" y="356.9951">Consumer Module</text><!--MD5=[285799c56db97b1ff04073a80c32724e]
class KafkaTopicConfig--><rect codeLine="6" fill="#FEFECE" filter="url(#f1gtkmahyy9zwr)" height="78.4141" id="KafkaTopicConfig" style="stroke:#A80036;stroke-width:1.5;" width="311" x="3386.5" y="439"/><ellipse cx="3480.25" cy="455" fill="#ADD1B2" rx="11" ry="11" style="stroke:#A80036;stroke-width:1.0;"/><path d="M3482.5938,450.6719 C3481.6563,450.2344 3481.0625,450.0938 3480.1875,450.0938 C3477.5625,450.0938 3475.5625,452.1719 3475.5625,454.8906 L3475.5625,456.0156 C3475.5625,458.5938 3477.6719,460.4844 3480.5625,460.4844 C3481.7813,460.4844 3482.9375,460.1875 3483.6875,459.6406 C3484.2656,459.2344 3484.5938,458.7813 3484.5938,458.3906 C3484.5938,457.9375 3484.2031,457.5469 3483.7344,457.5469 C3483.5156,457.5469 3483.3125,457.625 3483.125,457.8125 C3482.6719,458.2969 3482.6719,458.2969 3482.4844,458.3906 C3482.0625,458.6563 3481.375,458.7813 3480.6094,458.7813 C3478.5625,458.7813 3477.2656,457.6875 3477.2656,455.9844 L3477.2656,454.8906 C3477.2656,453.1094 3478.5156,451.7969 3480.25,451.7969 C3480.8281,451.7969 3481.4375,451.9531 3481.9063,452.2031 C3482.3906,452.4844 3482.5625,452.7031 3482.6563,453.1094 C3482.7188,453.5156 3482.75,453.6406 3482.8906,453.7656 C3483.0313,453.9063 3483.2656,454.0156 3483.4844,454.0156 C3483.75,454.0156 3484.0156,453.875 3484.1875,453.6563 C3484.2969,453.5 3484.3281,453.3125 3484.3281,452.8906 L3484.3281,451.4688 C3484.3281,451.0313 3484.3125,450.9063 3484.2188,450.75 C3484.0625,450.4844 3483.7813,450.3438 3483.4844,450.3438 C3483.1875,450.3438 3482.9844,450.4375 3482.7656,450.75 L3482.5938,450.6719 Z " fill="#000000"/><ellipse cx="3505.75" cy="454.5" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacing" textLength="104" x="3511.75" y="459.1543">KafkaTopicConfig</text><line style="stroke:#A80036;stroke-width:1.5;" x1="3387.5" x2="3696.5" y1="471" y2="471"/><ellipse cx="3397.5" cy="482" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="285" x="3406.5" y="485.2104">KafkaAdmin kafkaAdmin (String bootstrapAddress)</text><ellipse cx="3397.5" cy="494.8047" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="105" x="3406.5" y="498.0151">NewTopic topic1 ()</text><ellipse cx="3397.5" cy="507.6094" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="105" x="3406.5" y="510.8198">NewTopic topic2 ()</text><!--MD5=[ffaa840b41df4c7c9690665be51f9615]
class KafkaConstants--><rect codeLine="13" fill="#FEFECE" filter="url(#f1gtkmahyy9zwr)" height="104.0234" id="KafkaConstants" style="stroke:#A80036;stroke-width:1.5;" width="311" x="3040.5" y="426"/><ellipse cx="3140.25" cy="442" fill="#ADD1B2" rx="11" ry="11" style="stroke:#A80036;stroke-width:1.0;"/><path d="M3142.5938,437.6719 C3141.6563,437.2344 3141.0625,437.0938 3140.1875,437.0938 C3137.5625,437.0938 3135.5625,439.1719 3135.5625,441.8906 L3135.5625,443.0156 C3135.5625,445.5938 3137.6719,447.4844 3140.5625,447.4844 C3141.7813,447.4844 3142.9375,447.1875 3143.6875,446.6406 C3144.2656,446.2344 3144.5938,445.7813 3144.5938,445.3906 C3144.5938,444.9375 3144.2031,444.5469 3143.7344,444.5469 C3143.5156,444.5469 3143.3125,444.625 3143.125,444.8125 C3142.6719,445.2969 3142.6719,445.2969 3142.4844,445.3906 C3142.0625,445.6563 3141.375,445.7813 3140.6094,445.7813 C3138.5625,445.7813 3137.2656,444.6875 3137.2656,442.9844 L3137.2656,441.8906 C3137.2656,440.1094 3138.5156,438.7969 3140.25,438.7969 C3140.8281,438.7969 3141.4375,438.9531 3141.9063,439.2031 C3142.3906,439.4844 3142.5625,439.7031 3142.6563,440.1094 C3142.7188,440.5156 3142.75,440.6406 3142.8906,440.7656 C3143.0313,440.9063 3143.2656,441.0156 3143.4844,441.0156 C3143.75,441.0156 3144.0156,440.875 3144.1875,440.6563 C3144.2969,440.5 3144.3281,440.3125 3144.3281,439.8906 L3144.3281,438.4688 C3144.3281,438.0313 3144.3125,437.9063 3144.2188,437.75 C3144.0625,437.4844 3143.7813,437.3438 3143.4844,437.3438 C3143.1875,437.3438 3142.9844,437.4375 3142.7656,437.75 L3142.5938,437.6719 Z " fill="#000000"/><ellipse cx="3165.75" cy="441.5" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacing" textLength="92" x="3171.75" y="446.1543">KafkaConstants</text><line style="stroke:#A80036;stroke-width:1.5;" x1="3041.5" x2="3350.5" y1="458" y2="458"/><rect fill="none" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="3048.5" y="466"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="127" x="3060.5" y="472.2104">String DEFAULT_TOPIC</text><ellipse cx="3051.5" cy="481.8047" fill="none" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="208" x="3060.5" y="485.0151">String KAFKA_TOPIC_STRING_STRING</text><ellipse cx="3051.5" cy="494.6094" fill="none" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="285" x="3060.5" y="497.8198">String KAFKA_TOPIC_STRING_STRING_WITH_FILTER</text><ellipse cx="3051.5" cy="507.4141" fill="none" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="193" x="3060.5" y="510.6245">String KAFKA_TOPIC_STRING_POJO</text><ellipse cx="3051.5" cy="520.2188" fill="none" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="136" x="3060.5" y="523.4292">String KAFKA_GROUP_ID</text><!--MD5=[767114e114d8ab9e6152ce660e6efb54]
class MessageLog--><rect codeLine="22" fill="#FEFECE" filter="url(#f1gtkmahyy9zwr)" height="65.6094" id="MessageLog" style="stroke:#A80036;stroke-width:1.5;" width="191" x="2814.5" y="445"/><ellipse cx="2861.75" cy="461" fill="#ADD1B2" rx="11" ry="11" style="stroke:#A80036;stroke-width:1.0;"/><path d="M2864.0938,456.6719 C2863.1563,456.2344 2862.5625,456.0938 2861.6875,456.0938 C2859.0625,456.0938 2857.0625,458.1719 2857.0625,460.8906 L2857.0625,462.0156 C2857.0625,464.5938 2859.1719,466.4844 2862.0625,466.4844 C2863.2813,466.4844 2864.4375,466.1875 2865.1875,465.6406 C2865.7656,465.2344 2866.0938,464.7813 2866.0938,464.3906 C2866.0938,463.9375 2865.7031,463.5469 2865.2344,463.5469 C2865.0156,463.5469 2864.8125,463.625 2864.625,463.8125 C2864.1719,464.2969 2864.1719,464.2969 2863.9844,464.3906 C2863.5625,464.6563 2862.875,464.7813 2862.1094,464.7813 C2860.0625,464.7813 2858.7656,463.6875 2858.7656,461.9844 L2858.7656,460.8906 C2858.7656,459.1094 2860.0156,457.7969 2861.75,457.7969 C2862.3281,457.7969 2862.9375,457.9531 2863.4063,458.2031 C2863.8906,458.4844 2864.0625,458.7031 2864.1563,459.1094 C2864.2188,459.5156 2864.25,459.6406 2864.3906,459.7656 C2864.5313,459.9063 2864.7656,460.0156 2864.9844,460.0156 C2865.25,460.0156 2865.5156,459.875 2865.6875,459.6563 C2865.7969,459.5 2865.8281,459.3125 2865.8281,458.8906 L2865.8281,457.4688 C2865.8281,457.0313 2865.8125,456.9063 2865.7188,456.75 C2865.5625,456.4844 2865.2813,456.3438 2864.9844,456.3438 C2864.6875,456.3438 2864.4844,456.4375 2864.2656,456.75 L2864.0938,456.6719 Z " fill="#000000"/><ellipse cx="2887.25" cy="460.5" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacing" textLength="77" x="2893.25" y="465.1543">MessageLog</text><line style="stroke:#A80036;stroke-width:1.5;" x1="2815.5" x2="3004.5" y1="477" y2="477"/><rect fill="none" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="2822.5" y="485"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="90" x="2834.5" y="491.2104">String message</text><rect fill="none" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="2822.5" y="497.8047"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="165" x="2834.5" y="504.0151">LocalDateTime creationTime</text><!--MD5=[0e6d94074ab94147d882d0b01e6679e4]
class KafkaProducerConfig--><rect codeLine="32" fill="#FEFECE" filter="url(#f1gtkmahyy9zwr)" height="91.2188" id="KafkaProducerConfig" style="stroke:#A80036;stroke-width:1.5;" width="741" x="2016.5" y="41"/><ellipse cx="2314.75" cy="57" fill="#ADD1B2" rx="11" ry="11" style="stroke:#A80036;stroke-width:1.0;"/><path d="M2317.0938,52.6719 C2316.1563,52.2344 2315.5625,52.0938 2314.6875,52.0938 C2312.0625,52.0938 2310.0625,54.1719 2310.0625,56.8906 L2310.0625,58.0156 C2310.0625,60.5938 2312.1719,62.4844 2315.0625,62.4844 C2316.2813,62.4844 2317.4375,62.1875 2318.1875,61.6406 C2318.7656,61.2344 2319.0938,60.7813 2319.0938,60.3906 C2319.0938,59.9375 2318.7031,59.5469 2318.2344,59.5469 C2318.0156,59.5469 2317.8125,59.625 2317.625,59.8125 C2317.1719,60.2969 2317.1719,60.2969 2316.9844,60.3906 C2316.5625,60.6563 2315.875,60.7813 2315.1094,60.7813 C2313.0625,60.7813 2311.7656,59.6875 2311.7656,57.9844 L2311.7656,56.8906 C2311.7656,55.1094 2313.0156,53.7969 2314.75,53.7969 C2315.3281,53.7969 2315.9375,53.9531 2316.4063,54.2031 C2316.8906,54.4844 2317.0625,54.7031 2317.1563,55.1094 C2317.2188,55.5156 2317.25,55.6406 2317.3906,55.7656 C2317.5313,55.9063 2317.7656,56.0156 2317.9844,56.0156 C2318.25,56.0156 2318.5156,55.875 2318.6875,55.6563 C2318.7969,55.5 2318.8281,55.3125 2318.8281,54.8906 L2318.8281,53.4688 C2318.8281,53.0313 2318.8125,52.9063 2318.7188,52.75 C2318.5625,52.4844 2318.2813,52.3438 2317.9844,52.3438 C2317.6875,52.3438 2317.4844,52.4375 2317.2656,52.75 L2317.0938,52.6719 Z " fill="#000000"/><ellipse cx="2340.25" cy="56.5" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacing" textLength="125" x="2346.25" y="61.1543">KafkaProducerConfig</text><line style="stroke:#A80036;stroke-width:1.5;" x1="2017.5" x2="2756.5" y1="73" y2="73"/><ellipse cx="2027.5" cy="84" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="421" x="2036.5" y="87.2104">ProducerFactory&lt;String String&gt; producerFactory (String bootstrapAddress)</text><ellipse cx="2027.5" cy="96.8047" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="548" x="2036.5" y="100.0151">KafkaTemplate&lt;String String&gt; kafkaTemplate (ProducerFactory&lt;String String&gt; producerFactory)</text><ellipse cx="2027.5" cy="109.6094" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="522" x="2036.5" y="112.8198">ProducerFactory&lt;String MessageLog&gt; customPojoProducerFactory (String bootstrapAddress)</text><ellipse cx="2027.5" cy="122.4141" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="715" x="2036.5" y="125.6245">KafkaTemplate&lt;String MessageLog&gt; kafkaTemplateWithCustomPojo (ProducerFactory&lt;String MessageLog&gt; producerFactory)</text><!--MD5=[2047db6834670adb5ffb88c7a6b90368]
class CustomPojoKafkaListener--><rect codeLine="40" fill="#FEFECE" filter="url(#f1gtkmahyy9zwr)" height="86.4141" id="CustomPojoKafkaListener" style="stroke:#A80036;stroke-width:1.5;" width="354" x="1848" y="211.5"/><ellipse cx="1939.75" cy="227.5" fill="#ADD1B2" rx="11" ry="11" style="stroke:#A80036;stroke-width:1.0;"/><path d="M1942.0938,223.1719 C1941.1563,222.7344 1940.5625,222.5938 1939.6875,222.5938 C1937.0625,222.5938 1935.0625,224.6719 1935.0625,227.3906 L1935.0625,228.5156 C1935.0625,231.0938 1937.1719,232.9844 1940.0625,232.9844 C1941.2813,232.9844 1942.4375,232.6875 1943.1875,232.1406 C1943.7656,231.7344 1944.0938,231.2813 1944.0938,230.8906 C1944.0938,230.4375 1943.7031,230.0469 1943.2344,230.0469 C1943.0156,230.0469 1942.8125,230.125 1942.625,230.3125 C1942.1719,230.7969 1942.1719,230.7969 1941.9844,230.8906 C1941.5625,231.1563 1940.875,231.2813 1940.1094,231.2813 C1938.0625,231.2813 1936.7656,230.1875 1936.7656,228.4844 L1936.7656,227.3906 C1936.7656,225.6094 1938.0156,224.2969 1939.75,224.2969 C1940.3281,224.2969 1940.9375,224.4531 1941.4063,224.7031 C1941.8906,224.9844 1942.0625,225.2031 1942.1563,225.6094 C1942.2188,226.0156 1942.25,226.1406 1942.3906,226.2656 C1942.5313,226.4063 1942.7656,226.5156 1942.9844,226.5156 C1943.25,226.5156 1943.5156,226.375 1943.6875,226.1563 C1943.7969,226 1943.8281,225.8125 1943.8281,225.3906 L1943.8281,223.9688 C1943.8281,223.5313 1943.8125,223.4063 1943.7188,223.25 C1943.5625,222.9844 1943.2813,222.8438 1942.9844,222.8438 C1942.6875,222.8438 1942.4844,222.9375 1942.2656,223.25 L1942.0938,223.1719 Z " fill="#000000"/><ellipse cx="1965.25" cy="227" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacing" textLength="151" x="1971.25" y="231.6543">CustomPojoKafkaListener</text><line style="stroke:#A80036;stroke-width:1.5;" x1="1849" x2="2201" y1="243.5" y2="243.5"/><rect fill="none" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="1856" y="251.5"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="128" x="1868" y="257.7104">MessageLog message</text><line style="stroke:#A80036;stroke-width:1.5;" x1="1849" x2="2201" y1="264.3047" y2="264.3047"/><ellipse cx="1859" cy="275.3047" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="328" x="1868" y="278.5151">void onSuccess (SendResult&lt;String MessageLog&gt; result)</text><ellipse cx="1859" cy="288.1094" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="212" x="1868" y="291.3198">void onFailure (Throwable exception)</text><!--MD5=[9ea9aefea0fc0bd6a985857681ad3bd4]
class ListenableFutureCallback--><rect fill="#FEFECE" filter="url(#f1gtkmahyy9zwr)" height="32" id="ListenableFutureCallback" style="stroke:#A80036;stroke-width:1.5;" width="183" x="1798.5" y="70.5"/><ellipse cx="1813.5" cy="86.5" fill="#B4A7E5" rx="11" ry="11" style="stroke:#A80036;stroke-width:1.0;"/><path d="M1814.4531,83.2813 L1816.1719,83.2813 C1816.5625,83.2813 1816.75,83.25 1816.875,83.1719 C1817.1406,83.0156 1817.2813,82.7344 1817.2813,82.4375 C1817.2813,82.1719 1817.1719,81.9063 1816.9375,81.7344 C1816.7656,81.625 1816.625,81.5938 1816.1719,81.5938 L1811.0313,81.5938 C1810.5938,81.5938 1810.4688,81.6094 1810.3125,81.7031 C1810.0625,81.8594 1809.9063,82.1563 1809.9063,82.4375 C1809.9063,82.7188 1810.0469,82.9688 1810.2656,83.1406 C1810.4219,83.25 1810.6094,83.2813 1811.0313,83.2813 L1812.75,83.2813 L1812.75,89.7969 L1811.0313,89.7969 C1810.5938,89.7969 1810.4688,89.8125 1810.3125,89.9219 C1810.0625,90.0781 1809.9063,90.3594 1809.9063,90.6563 C1809.9063,90.9063 1810.0469,91.1719 1810.2656,91.3281 C1810.4219,91.4531 1810.625,91.5 1811.0313,91.5 L1816.1719,91.5 C1816.9219,91.5 1817.2813,91.2188 1817.2813,90.6563 C1817.2813,90.375 1817.1719,90.125 1816.9375,89.9531 C1816.7656,89.8281 1816.625,89.7969 1816.1719,89.7969 L1814.4531,89.7969 L1814.4531,83.2813 Z " fill="#000000"/><text fill="#000000" font-family="sans-serif" font-size="12" font-style="italic" lengthAdjust="spacing" textLength="151" x="1827.5" y="90.6543">ListenableFutureCallback</text><!--MD5=[317644390a80ec8724509ef6406c3257]
class CustomStringKafkaListener--><rect codeLine="47" fill="#FEFECE" filter="url(#f1gtkmahyy9zwr)" height="86.4141" id="CustomStringKafkaListener" style="stroke:#A80036;stroke-width:1.5;" width="316" x="2237" y="211.5"/><ellipse cx="2304.75" cy="227.5" fill="#ADD1B2" rx="11" ry="11" style="stroke:#A80036;stroke-width:1.0;"/><path d="M2307.0938,223.1719 C2306.1563,222.7344 2305.5625,222.5938 2304.6875,222.5938 C2302.0625,222.5938 2300.0625,224.6719 2300.0625,227.3906 L2300.0625,228.5156 C2300.0625,231.0938 2302.1719,232.9844 2305.0625,232.9844 C2306.2813,232.9844 2307.4375,232.6875 2308.1875,232.1406 C2308.7656,231.7344 2309.0938,231.2813 2309.0938,230.8906 C2309.0938,230.4375 2308.7031,230.0469 2308.2344,230.0469 C2308.0156,230.0469 2307.8125,230.125 2307.625,230.3125 C2307.1719,230.7969 2307.1719,230.7969 2306.9844,230.8906 C2306.5625,231.1563 2305.875,231.2813 2305.1094,231.2813 C2303.0625,231.2813 2301.7656,230.1875 2301.7656,228.4844 L2301.7656,227.3906 C2301.7656,225.6094 2303.0156,224.2969 2304.75,224.2969 C2305.3281,224.2969 2305.9375,224.4531 2306.4063,224.7031 C2306.8906,224.9844 2307.0625,225.2031 2307.1563,225.6094 C2307.2188,226.0156 2307.25,226.1406 2307.3906,226.2656 C2307.5313,226.4063 2307.7656,226.5156 2307.9844,226.5156 C2308.25,226.5156 2308.5156,226.375 2308.6875,226.1563 C2308.7969,226 2308.8281,225.8125 2308.8281,225.3906 L2308.8281,223.9688 C2308.8281,223.5313 2308.8125,223.4063 2308.7188,223.25 C2308.5625,222.9844 2308.2813,222.8438 2307.9844,222.8438 C2307.6875,222.8438 2307.4844,222.9375 2307.2656,223.25 L2307.0938,223.1719 Z " fill="#000000"/><ellipse cx="2330.25" cy="227" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacing" textLength="161" x="2336.25" y="231.6543">CustomStringKafkaListener</text><line style="stroke:#A80036;stroke-width:1.5;" x1="2238" x2="2552" y1="243.5" y2="243.5"/><rect fill="none" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="2245" y="251.5"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="90" x="2257" y="257.7104">String message</text><line style="stroke:#A80036;stroke-width:1.5;" x1="2238" x2="2552" y1="264.3047" y2="264.3047"/><ellipse cx="2248" cy="275.3047" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="290" x="2257" y="278.5151">void onSuccess (SendResult&lt;String String&gt; result)</text><ellipse cx="2248" cy="288.1094" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="212" x="2257" y="291.3198">void onFailure (Throwable exception)</text><!--MD5=[84718776d214be480e4c259efcb737fc]
class Main--><rect codeLine="134" fill="#FEFECE" filter="url(#f1gtkmahyy9zwr)" height="124.8281" id="Main" style="stroke:#A80036;stroke-width:1.5;" width="297" x="1515.5" y="192"/><ellipse cx="1640.75" cy="208" fill="#ADD1B2" rx="11" ry="11" style="stroke:#A80036;stroke-width:1.0;"/><path d="M1643.0938,203.6719 C1642.1563,203.2344 1641.5625,203.0938 1640.6875,203.0938 C1638.0625,203.0938 1636.0625,205.1719 1636.0625,207.8906 L1636.0625,209.0156 C1636.0625,211.5938 1638.1719,213.4844 1641.0625,213.4844 C1642.2813,213.4844 1643.4375,213.1875 1644.1875,212.6406 C1644.7656,212.2344 1645.0938,211.7813 1645.0938,211.3906 C1645.0938,210.9375 1644.7031,210.5469 1644.2344,210.5469 C1644.0156,210.5469 1643.8125,210.625 1643.625,210.8125 C1643.1719,211.2969 1643.1719,211.2969 1642.9844,211.3906 C1642.5625,211.6563 1641.875,211.7813 1641.1094,211.7813 C1639.0625,211.7813 1637.7656,210.6875 1637.7656,208.9844 L1637.7656,207.8906 C1637.7656,206.1094 1639.0156,204.7969 1640.75,204.7969 C1641.3281,204.7969 1641.9375,204.9531 1642.4063,205.2031 C1642.8906,205.4844 1643.0625,205.7031 1643.1563,206.1094 C1643.2188,206.5156 1643.25,206.6406 1643.3906,206.7656 C1643.5313,206.9063 1643.7656,207.0156 1643.9844,207.0156 C1644.25,207.0156 1644.5156,206.875 1644.6875,206.6563 C1644.7969,206.5 1644.8281,206.3125 1644.8281,205.8906 L1644.8281,204.4688 C1644.8281,204.0313 1644.8125,203.9063 1644.7188,203.75 C1644.5625,203.4844 1644.2813,203.3438 1643.9844,203.3438 C1643.6875,203.3438 1643.4844,203.4375 1643.2656,203.75 L1643.0938,203.6719 Z " fill="#000000"/><ellipse cx="1666.25" cy="207.5" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacing" textLength="27" x="1672.25" y="212.1543">Main</text><line style="stroke:#A80036;stroke-width:1.5;" x1="1516.5" x2="1811.5" y1="224" y2="224"/><rect fill="none" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="1523.5" y="232"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="271" x="1535.5" y="238.2104">ProducerMessageService sendMessageService</text><line style="stroke:#A80036;stroke-width:1.5;" x1="1516.5" x2="1811.5" y1="244.8047" y2="244.8047"/><ellipse cx="1526.5" cy="255.8047" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" text-decoration="underline" textLength="129" x="1535.5" y="259.0151">void main (String args)</text><ellipse cx="1526.5" cy="268.6094" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="119" x="1535.5" y="271.8198">void run (String args)</text><rect fill="#F24D5C" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="1523.5" y="278.4141"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="91" x="1535.5" y="284.6245">void sendPojo ()</text><rect fill="#F24D5C" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="1523.5" y="291.2188"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="101" x="1535.5" y="297.4292">void sendString ()</text><ellipse cx="1526.5" cy="307.0234" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" text-decoration="underline" textLength="129" x="1535.5" y="310.2339">void main (String args)</text><!--MD5=[34a2344cadfb5088924753e61221cd38]
class CommandLineRunner--><rect fill="#FEFECE" filter="url(#f1gtkmahyy9zwr)" height="32" id="CommandLineRunner" style="stroke:#A80036;stroke-width:1.5;" width="163" x="1582.5" y="70.5"/><ellipse cx="1597.5" cy="86.5" fill="#B4A7E5" rx="11" ry="11" style="stroke:#A80036;stroke-width:1.0;"/><path d="M1598.4531,83.2813 L1600.1719,83.2813 C1600.5625,83.2813 1600.75,83.25 1600.875,83.1719 C1601.1406,83.0156 1601.2813,82.7344 1601.2813,82.4375 C1601.2813,82.1719 1601.1719,81.9063 1600.9375,81.7344 C1600.7656,81.625 1600.625,81.5938 1600.1719,81.5938 L1595.0313,81.5938 C1594.5938,81.5938 1594.4688,81.6094 1594.3125,81.7031 C1594.0625,81.8594 1593.9063,82.1563 1593.9063,82.4375 C1593.9063,82.7188 1594.0469,82.9688 1594.2656,83.1406 C1594.4219,83.25 1594.6094,83.2813 1595.0313,83.2813 L1596.75,83.2813 L1596.75,89.7969 L1595.0313,89.7969 C1594.5938,89.7969 1594.4688,89.8125 1594.3125,89.9219 C1594.0625,90.0781 1593.9063,90.3594 1593.9063,90.6563 C1593.9063,90.9063 1594.0469,91.1719 1594.2656,91.3281 C1594.4219,91.4531 1594.625,91.5 1595.0313,91.5 L1600.1719,91.5 C1600.9219,91.5 1601.2813,91.2188 1601.2813,90.6563 C1601.2813,90.375 1601.1719,90.125 1600.9375,89.9531 C1600.7656,89.8281 1600.625,89.7969 1600.1719,89.7969 L1598.4531,89.7969 L1598.4531,83.2813 Z " fill="#000000"/><text fill="#000000" font-family="sans-serif" font-size="12" font-style="italic" lengthAdjust="spacing" textLength="131" x="1611.5" y="90.6543">CommandLineRunner</text><!--MD5=[469155a6061eac68e8d5d17bb8ad37b7]
class ProducerMessageService--><rect codeLine="62" fill="#FEFECE" filter="url(#f1gtkmahyy9zwr)" height="112.0234" id="ProducerMessageService" style="stroke:#A80036;stroke-width:1.5;" width="490" x="2268" y="422"/><ellipse cx="2425.75" cy="438" fill="#ADD1B2" rx="11" ry="11" style="stroke:#A80036;stroke-width:1.0;"/><path d="M2428.0938,433.6719 C2427.1563,433.2344 2426.5625,433.0938 2425.6875,433.0938 C2423.0625,433.0938 2421.0625,435.1719 2421.0625,437.8906 L2421.0625,439.0156 C2421.0625,441.5938 2423.1719,443.4844 2426.0625,443.4844 C2427.2813,443.4844 2428.4375,443.1875 2429.1875,442.6406 C2429.7656,442.2344 2430.0938,441.7813 2430.0938,441.3906 C2430.0938,440.9375 2429.7031,440.5469 2429.2344,440.5469 C2429.0156,440.5469 2428.8125,440.625 2428.625,440.8125 C2428.1719,441.2969 2428.1719,441.2969 2427.9844,441.3906 C2427.5625,441.6563 2426.875,441.7813 2426.1094,441.7813 C2424.0625,441.7813 2422.7656,440.6875 2422.7656,438.9844 L2422.7656,437.8906 C2422.7656,436.1094 2424.0156,434.7969 2425.75,434.7969 C2426.3281,434.7969 2426.9375,434.9531 2427.4063,435.2031 C2427.8906,435.4844 2428.0625,435.7031 2428.1563,436.1094 C2428.2188,436.5156 2428.25,436.6406 2428.3906,436.7656 C2428.5313,436.9063 2428.7656,437.0156 2428.9844,437.0156 C2429.25,437.0156 2429.5156,436.875 2429.6875,436.6563 C2429.7969,436.5 2429.8281,436.3125 2429.8281,435.8906 L2429.8281,434.4688 C2429.8281,434.0313 2429.8125,433.9063 2429.7188,433.75 C2429.5625,433.4844 2429.2813,433.3438 2428.9844,433.3438 C2428.6875,433.3438 2428.4844,433.4375 2428.2656,433.75 L2428.0938,433.6719 Z " fill="#000000"/><ellipse cx="2451.25" cy="437.5" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacing" textLength="155" x="2457.25" y="442.1543">ProducerMessageService</text><line style="stroke:#A80036;stroke-width:1.5;" x1="2269" x2="2757" y1="454" y2="454"/><rect fill="none" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="2276" y="462"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="263" x="2288" y="468.2104">KafkaTemplate&lt;String String&gt; kafkaTemplate</text><rect fill="none" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="2276" y="474.8047"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="349" x="2288" y="481.0151">KafkaTemplate&lt;String MessageLog&gt; kafkaTemplateWithPojo</text><line style="stroke:#A80036;stroke-width:1.5;" x1="2269" x2="2757" y1="487.6094" y2="487.6094"/><ellipse cx="2279" cy="498.6094" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="464" x="2288" y="501.8198">void sendAsynchronousStringMessage (String asynchronousMessage,String topic)</text><ellipse cx="2279" cy="511.4141" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="455" x="2288" y="514.6245">void sendAsynchronousPojoMessage (MessageLog customMessage,String topic)</text><ellipse cx="2279" cy="524.2188" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="384" x="2288" y="527.4292">void sendSynchronousStringMessage (String synchronousMessage)</text><!--MD5=[55aceffbfca4889b468bf2ddbc0cabcf]
class KafkaTemplate--><rect fill="#FEFECE" filter="url(#f1gtkmahyy9zwr)" height="32" id="KafkaTemplate" style="stroke:#A80036;stroke-width:1.5;" width="121" x="2213.5" y="686"/><ellipse cx="2228.5" cy="702" fill="#ADD1B2" rx="11" ry="11" style="stroke:#A80036;stroke-width:1.0;"/><path d="M2230.8438,697.6719 C2229.9063,697.2344 2229.3125,697.0938 2228.4375,697.0938 C2225.8125,697.0938 2223.8125,699.1719 2223.8125,701.8906 L2223.8125,703.0156 C2223.8125,705.5938 2225.9219,707.4844 2228.8125,707.4844 C2230.0313,707.4844 2231.1875,707.1875 2231.9375,706.6406 C2232.5156,706.2344 2232.8438,705.7813 2232.8438,705.3906 C2232.8438,704.9375 2232.4531,704.5469 2231.9844,704.5469 C2231.7656,704.5469 2231.5625,704.625 2231.375,704.8125 C2230.9219,705.2969 2230.9219,705.2969 2230.7344,705.3906 C2230.3125,705.6563 2229.625,705.7813 2228.8594,705.7813 C2226.8125,705.7813 2225.5156,704.6875 2225.5156,702.9844 L2225.5156,701.8906 C2225.5156,700.1094 2226.7656,698.7969 2228.5,698.7969 C2229.0781,698.7969 2229.6875,698.9531 2230.1563,699.2031 C2230.6406,699.4844 2230.8125,699.7031 2230.9063,700.1094 C2230.9688,700.5156 2231,700.6406 2231.1406,700.7656 C2231.2813,700.9063 2231.5156,701.0156 2231.7344,701.0156 C2232,701.0156 2232.2656,700.875 2232.4375,700.6563 C2232.5469,700.5 2232.5781,700.3125 2232.5781,699.8906 L2232.5781,698.4688 C2232.5781,698.0313 2232.5625,697.9063 2232.4688,697.75 C2232.3125,697.4844 2232.0313,697.3438 2231.7344,697.3438 C2231.4375,697.3438 2231.2344,697.4375 2231.0156,697.75 L2230.8438,697.6719 Z " fill="#000000"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacing" textLength="89" x="2242.5" y="706.1543">KafkaTemplate</text><!--MD5=[4fa8d58144733848e206e99ae5a1d2c2]
class ProducerTest--><rect codeLine="71" fill="#FEFECE" filter="url(#f1gtkmahyy9zwr)" height="150.4375" id="ProducerTest" style="stroke:#A80036;stroke-width:1.5;" width="393" x="1839.5" y="403"/><ellipse cx="1986.25" cy="419" fill="#ADD1B2" rx="11" ry="11" style="stroke:#A80036;stroke-width:1.0;"/><path d="M1988.5938,414.6719 C1987.6563,414.2344 1987.0625,414.0938 1986.1875,414.0938 C1983.5625,414.0938 1981.5625,416.1719 1981.5625,418.8906 L1981.5625,420.0156 C1981.5625,422.5938 1983.6719,424.4844 1986.5625,424.4844 C1987.7813,424.4844 1988.9375,424.1875 1989.6875,423.6406 C1990.2656,423.2344 1990.5938,422.7813 1990.5938,422.3906 C1990.5938,421.9375 1990.2031,421.5469 1989.7344,421.5469 C1989.5156,421.5469 1989.3125,421.625 1989.125,421.8125 C1988.6719,422.2969 1988.6719,422.2969 1988.4844,422.3906 C1988.0625,422.6563 1987.375,422.7813 1986.6094,422.7813 C1984.5625,422.7813 1983.2656,421.6875 1983.2656,419.9844 L1983.2656,418.8906 C1983.2656,417.1094 1984.5156,415.7969 1986.25,415.7969 C1986.8281,415.7969 1987.4375,415.9531 1987.9063,416.2031 C1988.3906,416.4844 1988.5625,416.7031 1988.6563,417.1094 C1988.7188,417.5156 1988.75,417.6406 1988.8906,417.7656 C1989.0313,417.9063 1989.2656,418.0156 1989.4844,418.0156 C1989.75,418.0156 1990.0156,417.875 1990.1875,417.6563 C1990.2969,417.5 1990.3281,417.3125 1990.3281,416.8906 L1990.3281,415.4688 C1990.3281,415.0313 1990.3125,414.9063 1990.2188,414.75 C1990.0625,414.4844 1989.7813,414.3438 1989.4844,414.3438 C1989.1875,414.3438 1988.9844,414.4375 1988.7656,414.75 L1988.5938,414.6719 Z " fill="#000000"/><polygon fill="#4177AF" points="2011.75,414.5,2007.75,420.5,2015.75,420.5" style="stroke:#1963A0;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacing" textLength="80" x="2017.75" y="423.1543">ProducerTest</text><line style="stroke:#A80036;stroke-width:1.5;" x1="1840.5" x2="2231.5" y1="435" y2="435"/><rect fill="none" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="1847.5" y="443"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="265" x="1859.5" y="449.2104">EmbeddedKafkaBroker embeddedKafkaBroker</text><rect fill="none" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="1847.5" y="455.8047"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="294" x="1859.5" y="462.0151">KafkaTemplate&lt;String String&gt; producerStringString</text><rect fill="none" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="1847.5" y="468.6094"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="322" x="1859.5" y="474.8198">KafkaTemplate&lt;String MessageLog&gt; producerStringPojo</text><line style="stroke:#A80036;stroke-width:1.5;" x1="1840.5" x2="2231.5" y1="481.4141" y2="481.4141"/><polygon fill="#4177AF" points="1850.5,488.4141,1846.5,494.4141,1854.5,494.4141" style="stroke:#1963A0;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="177" x="1859.5" y="495.6245">void testProducerStringString ()</text><polygon fill="#4177AF" points="1850.5,501.2188,1846.5,507.2188,1854.5,507.2188" style="stroke:#1963A0;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="167" x="1859.5" y="508.4292">void testProducerStringPojo ()</text><polygon fill="#4177AF" points="1850.5,514.0234,1846.5,520.0234,1854.5,520.0234" style="stroke:#1963A0;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="205" x="1859.5" y="521.2339">void testProducerStringStringFilter ()</text><rect fill="#F24D5C" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="1847.5" y="527.8281"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="339" x="1859.5" y="534.0386">Consumer&lt;String String&gt; configureConsumerStringString ()</text><rect fill="#F24D5C" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="1847.5" y="540.6328"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="367" x="1859.5" y="546.8433">Consumer&lt;String MessageLog&gt; configureConsumerStringPojo ()</text><!--MD5=[6c34fbdff4a8a552da7dd38477d1ee7c]
class EmbeddedKafkaBroker--><rect fill="#FEFECE" filter="url(#f1gtkmahyy9zwr)" height="32" id="EmbeddedKafkaBroker" style="stroke:#A80036;stroke-width:1.5;" width="172" x="1565" y="686"/><ellipse cx="1580" cy="702" fill="#ADD1B2" rx="11" ry="11" style="stroke:#A80036;stroke-width:1.0;"/><path d="M1582.3438,697.6719 C1581.4063,697.2344 1580.8125,697.0938 1579.9375,697.0938 C1577.3125,697.0938 1575.3125,699.1719 1575.3125,701.8906 L1575.3125,703.0156 C1575.3125,705.5938 1577.4219,707.4844 1580.3125,707.4844 C1581.5313,707.4844 1582.6875,707.1875 1583.4375,706.6406 C1584.0156,706.2344 1584.3438,705.7813 1584.3438,705.3906 C1584.3438,704.9375 1583.9531,704.5469 1583.4844,704.5469 C1583.2656,704.5469 1583.0625,704.625 1582.875,704.8125 C1582.4219,705.2969 1582.4219,705.2969 1582.2344,705.3906 C1581.8125,705.6563 1581.125,705.7813 1580.3594,705.7813 C1578.3125,705.7813 1577.0156,704.6875 1577.0156,702.9844 L1577.0156,701.8906 C1577.0156,700.1094 1578.2656,698.7969 1580,698.7969 C1580.5781,698.7969 1581.1875,698.9531 1581.6563,699.2031 C1582.1406,699.4844 1582.3125,699.7031 1582.4063,700.1094 C1582.4688,700.5156 1582.5,700.6406 1582.6406,700.7656 C1582.7813,700.9063 1583.0156,701.0156 1583.2344,701.0156 C1583.5,701.0156 1583.7656,700.875 1583.9375,700.6563 C1584.0469,700.5 1584.0781,700.3125 1584.0781,699.8906 L1584.0781,698.4688 C1584.0781,698.0313 1584.0625,697.9063 1583.9688,697.75 C1583.8125,697.4844 1583.5313,697.3438 1583.2344,697.3438 C1582.9375,697.3438 1582.7344,697.4375 1582.5156,697.75 L1582.3438,697.6719 Z " fill="#000000"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacing" textLength="140" x="1594" y="706.1543">EmbeddedKafkaBroker</text><!--MD5=[f8bbe08000c1c1a163b213455aa9f4fc]
class SimpleKafkaTest--><rect codeLine="84" fill="#FEFECE" filter="url(#f1gtkmahyy9zwr)" height="124.8281" id="SimpleKafkaTest" style="stroke:#A80036;stroke-width:1.5;" width="307" x="1497.5" y="415.5"/><ellipse cx="1591.25" cy="431.5" fill="#ADD1B2" rx="11" ry="11" style="stroke:#A80036;stroke-width:1.0;"/><path d="M1593.5938,427.1719 C1592.6563,426.7344 1592.0625,426.5938 1591.1875,426.5938 C1588.5625,426.5938 1586.5625,428.6719 1586.5625,431.3906 L1586.5625,432.5156 C1586.5625,435.0938 1588.6719,436.9844 1591.5625,436.9844 C1592.7813,436.9844 1593.9375,436.6875 1594.6875,436.1406 C1595.2656,435.7344 1595.5938,435.2813 1595.5938,434.8906 C1595.5938,434.4375 1595.2031,434.0469 1594.7344,434.0469 C1594.5156,434.0469 1594.3125,434.125 1594.125,434.3125 C1593.6719,434.7969 1593.6719,434.7969 1593.4844,434.8906 C1593.0625,435.1563 1592.375,435.2813 1591.6094,435.2813 C1589.5625,435.2813 1588.2656,434.1875 1588.2656,432.4844 L1588.2656,431.3906 C1588.2656,429.6094 1589.5156,428.2969 1591.25,428.2969 C1591.8281,428.2969 1592.4375,428.4531 1592.9063,428.7031 C1593.3906,428.9844 1593.5625,429.2031 1593.6563,429.6094 C1593.7188,430.0156 1593.75,430.1406 1593.8906,430.2656 C1594.0313,430.4063 1594.2656,430.5156 1594.4844,430.5156 C1594.75,430.5156 1595.0156,430.375 1595.1875,430.1563 C1595.2969,430 1595.3281,429.8125 1595.3281,429.3906 L1595.3281,427.9688 C1595.3281,427.5313 1595.3125,427.4063 1595.2188,427.25 C1595.0625,426.9844 1594.7813,426.8438 1594.4844,426.8438 C1594.1875,426.8438 1593.9844,426.9375 1593.7656,427.25 L1593.5938,427.1719 Z " fill="#000000"/><polygon fill="#4177AF" points="1616.75,427,1612.75,433,1620.75,433" style="stroke:#1963A0;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacing" textLength="100" x="1622.75" y="435.6543">SimpleKafkaTest</text><line style="stroke:#A80036;stroke-width:1.5;" x1="1498.5" x2="1803.5" y1="447.5" y2="447.5"/><polygon fill="none" points="1508.5,453.5,1512.5,457.5,1508.5,461.5,1504.5,457.5" style="stroke:#B38D22;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" text-decoration="underline" textLength="70" x="1517.5" y="461.7104">String TOPIC</text><rect fill="none" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="1505.5" y="468.3047"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" text-decoration="underline" textLength="118" x="1517.5" y="474.5151">String KAFKA_GROUP</text><rect fill="none" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="1505.5" y="481.1094"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="265" x="1517.5" y="487.3198">EmbeddedKafkaBroker embeddedKafkaBroker</text><line style="stroke:#A80036;stroke-width:1.5;" x1="1498.5" x2="1803.5" y1="493.9141" y2="493.9141"/><polygon fill="#4177AF" points="1508.5,500.9141,1504.5,506.9141,1512.5,506.9141" style="stroke:#1963A0;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="188" x="1517.5" y="508.1245">void testReceivingKafkaEvents ()</text><rect fill="#F24D5C" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="1505.5" y="514.7188"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="281" x="1517.5" y="520.9292">Consumer&lt;Integer String&gt; configureConsumer ()</text><rect fill="#F24D5C" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="1505.5" y="527.5234"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="263" x="1517.5" y="533.7339">Producer&lt;Integer String&gt; configureProducer ()</text><!--MD5=[067c53683da6b885ca2463a43fb725d8]
class KafkaConsumerConfig--><rect codeLine="98" fill="#FEFECE" filter="url(#f1gtkmahyy9zwr)" height="201.6563" id="KafkaConsumerConfig" style="stroke:#A80036;stroke-width:1.5;" width="974" x="467" y="377"/><ellipse cx="878.25" cy="393" fill="#ADD1B2" rx="11" ry="11" style="stroke:#A80036;stroke-width:1.0;"/><path d="M880.5938,388.6719 C879.6563,388.2344 879.0625,388.0938 878.1875,388.0938 C875.5625,388.0938 873.5625,390.1719 873.5625,392.8906 L873.5625,394.0156 C873.5625,396.5938 875.6719,398.4844 878.5625,398.4844 C879.7813,398.4844 880.9375,398.1875 881.6875,397.6406 C882.2656,397.2344 882.5938,396.7813 882.5938,396.3906 C882.5938,395.9375 882.2031,395.5469 881.7344,395.5469 C881.5156,395.5469 881.3125,395.625 881.125,395.8125 C880.6719,396.2969 880.6719,396.2969 880.4844,396.3906 C880.0625,396.6563 879.375,396.7813 878.6094,396.7813 C876.5625,396.7813 875.2656,395.6875 875.2656,393.9844 L875.2656,392.8906 C875.2656,391.1094 876.5156,389.7969 878.25,389.7969 C878.8281,389.7969 879.4375,389.9531 879.9063,390.2031 C880.3906,390.4844 880.5625,390.7031 880.6563,391.1094 C880.7188,391.5156 880.75,391.6406 880.8906,391.7656 C881.0313,391.9063 881.2656,392.0156 881.4844,392.0156 C881.75,392.0156 882.0156,391.875 882.1875,391.6563 C882.2969,391.5 882.3281,391.3125 882.3281,390.8906 L882.3281,389.4688 C882.3281,389.0313 882.3125,388.9063 882.2188,388.75 C882.0625,388.4844 881.7813,388.3438 881.4844,388.3438 C881.1875,388.3438 880.9844,388.4375 880.7656,388.75 L880.5938,388.6719 Z " fill="#000000"/><ellipse cx="903.75" cy="392.5" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacing" textLength="132" x="909.75" y="397.1543">KafkaConsumerConfig</text><line style="stroke:#A80036;stroke-width:1.5;" x1="468" x2="1440" y1="409" y2="409"/><ellipse cx="478" cy="420" fill="none" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" text-decoration="underline" textLength="143" x="487" y="423.2104">String STRING_TO_FILTER</text><rect fill="none" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="475" y="429.8047"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="136" x="487" y="436.0151">String bootstrapAddress</text><line style="stroke:#A80036;stroke-width:1.5;" x1="468" x2="1440" y1="442.6094" y2="442.6094"/><ellipse cx="478" cy="453.6094" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="300" x="487" y="456.8198">ConsumerFactory&lt;String String&gt; consumerFactory ()</text><ellipse cx="478" cy="466.4141" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="799" x="487" y="469.6245">ConcurrentKafkaListenerContainerFactory&lt;String String&gt; kafkaListenerContainerFactory (ConsumerFactory&lt;String String&gt; consumerFactory)</text><ellipse cx="478" cy="479.2188" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="353" x="487" y="482.4292">ConsumerFactory&lt;String String&gt; consumerFactoryWithFilter ()</text><ellipse cx="478" cy="492.0234" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="852" x="487" y="495.2339">ConcurrentKafkaListenerContainerFactory&lt;String String&gt; kafkaListenerContainerFactoryWithFilter (ConsumerFactory&lt;String String&gt; consumerFactory)</text><ellipse cx="478" cy="504.8281" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="386" x="487" y="508.0386">ConsumerFactory&lt;String MessageLog&gt; consumerFactoryWithPojo ()</text><ellipse cx="478" cy="517.6328" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="923" x="487" y="520.8433">ConcurrentKafkaListenerContainerFactory&lt;String MessageLog&gt; kafkaListenerContainerFactoryWithPojo (ConsumerFactory&lt;String MessageLog&gt; consumerFactory)</text><ellipse cx="478" cy="530.4375" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="879" x="487" y="533.6479">ConcurrentKafkaListenerContainerFactory&lt;String String&gt; filterKafkaListenerContainerFactory (ConsumerFactory&lt;String String&gt; consumerFactoryWithFilter)</text><ellipse cx="478" cy="543.2422" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="948" x="487" y="546.4526">ConcurrentKafkaListenerContainerFactory&lt;String MessageLog&gt; pojoKafkaListenerContainerFactory (ConsumerFactory&lt;String MessageLog&gt; consumerFactoryWithPojo)</text><rect fill="#F24D5C" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="475" y="553.0469"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="416" x="487" y="559.2573">RecordFilterStrategy&lt;String String&gt; createCustomRecordFilterStrategy ()</text><rect fill="#F24D5C" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="475" y="565.8516"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="256" x="487" y="572.062">Map&lt;String Object&gt; createKafkaProperties ()</text><!--MD5=[65410e8f67890bbbbc59f64c49df1065]
class AbstractListener--><rect codeLine="113" fill="#FEFECE" filter="url(#f1gtkmahyy9zwr)" height="86.4141" id="AbstractListener" style="stroke:#A80036;stroke-width:1.5;" width="427" x="206.5" y="659"/><ellipse cx="360.75" cy="675" fill="#A9DCDF" rx="11" ry="11" style="stroke:#A80036;stroke-width:1.0;"/><path d="M362.8281,676.8125 L363.2188,677.7969 L362.8281,677.7969 C362.375,677.7969 362.2656,677.8125 362.1094,677.9219 C361.8594,678.0781 361.7031,678.3594 361.7031,678.6563 C361.7031,678.9219 361.8438,679.1719 362.0625,679.3281 C362.2031,679.4531 362.4063,679.5 362.8281,679.5 L365.1875,679.5 C365.5469,679.5 365.7656,679.4688 365.9063,679.375 C366.1563,679.2344 366.3125,678.9375 366.3125,678.6563 C366.3125,678.375 366.1719,678.125 365.9531,677.9688 C365.7813,677.8281 365.625,677.7969 365.1563,677.7969 L361.7656,669.5938 L358.0938,669.5938 C357.6406,669.5938 357.5156,669.6094 357.3594,669.7031 C357.1094,669.875 356.9531,670.1563 356.9531,670.4375 C356.9531,670.7188 357.0938,670.9688 357.3125,671.1406 C357.4844,671.25 357.6563,671.2813 358.0938,671.2813 L359.1719,671.2813 L356.5313,677.7969 C356.1094,677.7969 355.9531,677.8125 355.7969,677.9219 C355.5469,678.0781 355.3906,678.3594 355.3906,678.6563 C355.3906,679.2188 355.7656,679.5 356.5156,679.5 L358.7813,679.5 C359.1406,679.5 359.3594,679.4688 359.4844,679.375 C359.75,679.2344 359.8906,678.9375 359.8906,678.6563 C359.8906,678.375 359.7656,678.125 359.5469,677.9531 C359.375,677.8281 359.2344,677.7969 358.7813,677.7969 L358.3906,677.7969 L358.7813,676.8125 L362.8281,676.8125 Z M362.125,675.1094 L359.4531,675.1094 L360.7969,671.8438 L362.125,675.1094 Z " fill="#000000"/><ellipse cx="386.25" cy="674.5" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="12" font-style="italic" lengthAdjust="spacing" textLength="99" x="392.25" y="679.1543">AbstractListener</text><line style="stroke:#A80036;stroke-width:1.5;" x1="207.5" x2="632.5" y1="691" y2="691"/><polygon fill="none" points="217.5,697,221.5,701,217.5,705,213.5,701" style="stroke:#B38D22;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="126" x="226.5" y="705.2104">CountDownLatch latch</text><polygon fill="none" points="217.5,709.8047,221.5,713.8047,217.5,717.8047,213.5,713.8047" style="stroke:#B38D22;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="82" x="226.5" y="718.0151">String payload</text><line style="stroke:#A80036;stroke-width:1.5;" x1="207.5" x2="632.5" y1="724.6094" y2="724.6094"/><polygon fill="#FFFF44" points="217.5,730.6094,221.5,734.6094,217.5,738.6094,213.5,734.6094" style="stroke:#B38D22;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="401" x="226.5" y="738.8198">void processMessage (int listenerNumber,String message,String topic)</text><polygon fill="none" points="443.0282,745.4141,458.6124,759.7714,446.2577,766.3561" style="stroke:#A80036;stroke-width:1.0;"/><line style="stroke:#A80036;stroke-width:1.0;" x1="452.4351" x2="454" y1="763.0638" y2="766"/><line style="stroke:#A80036;stroke-width:1.0;" x1="384.1072" x2="367.365" y1="659" y2="638.846"/><!--MD5=[74fa213a62a9ced4c78aca167654350e]
class StringPojoListener--><rect codeLine="119" fill="#FEFECE" filter="url(#f1gtkmahyy9zwr)" height="52.8047" id="StringPojoListener" style="stroke:#A80036;stroke-width:1.5;" width="327" x="32.5" y="825"/><ellipse cx="132.25" cy="841" fill="#ADD1B2" rx="11" ry="11" style="stroke:#A80036;stroke-width:1.0;"/><path d="M134.5938,836.6719 C133.6563,836.2344 133.0625,836.0938 132.1875,836.0938 C129.5625,836.0938 127.5625,838.1719 127.5625,840.8906 L127.5625,842.0156 C127.5625,844.5938 129.6719,846.4844 132.5625,846.4844 C133.7813,846.4844 134.9375,846.1875 135.6875,845.6406 C136.2656,845.2344 136.5938,844.7813 136.5938,844.3906 C136.5938,843.9375 136.2031,843.5469 135.7344,843.5469 C135.5156,843.5469 135.3125,843.625 135.125,843.8125 C134.6719,844.2969 134.6719,844.2969 134.4844,844.3906 C134.0625,844.6563 133.375,844.7813 132.6094,844.7813 C130.5625,844.7813 129.2656,843.6875 129.2656,841.9844 L129.2656,840.8906 C129.2656,839.1094 130.5156,837.7969 132.25,837.7969 C132.8281,837.7969 133.4375,837.9531 133.9063,838.2031 C134.3906,838.4844 134.5625,838.7031 134.6563,839.1094 C134.7188,839.5156 134.75,839.6406 134.8906,839.7656 C135.0313,839.9063 135.2656,840.0156 135.4844,840.0156 C135.75,840.0156 136.0156,839.875 136.1875,839.6563 C136.2969,839.5 136.3281,839.3125 136.3281,838.8906 L136.3281,837.4688 C136.3281,837.0313 136.3125,836.9063 136.2188,836.75 C136.0625,836.4844 135.7813,836.3438 135.4844,836.3438 C135.1875,836.3438 134.9844,836.4375 134.7656,836.75 L134.5938,836.6719 Z " fill="#000000"/><ellipse cx="157.75" cy="840.5" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacing" textLength="108" x="163.75" y="845.1543">StringPojoListener</text><line style="stroke:#A80036;stroke-width:1.5;" x1="33.5" x2="358.5" y1="857" y2="857"/><ellipse cx="43.5" cy="868" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="301" x="52.5" y="871.2104">void greetingListener (MessageLog customMessage)</text><!--MD5=[056179d532fe1f5b3cdc8a7f0606b29d]
class StringStringListener--><rect codeLine="124" fill="#FEFECE" filter="url(#f1gtkmahyy9zwr)" height="52.8047" id="StringStringListener" style="stroke:#A80036;stroke-width:1.5;" width="359" x="394.5" y="825"/><ellipse cx="505.25" cy="841" fill="#ADD1B2" rx="11" ry="11" style="stroke:#A80036;stroke-width:1.0;"/><path d="M507.5938,836.6719 C506.6563,836.2344 506.0625,836.0938 505.1875,836.0938 C502.5625,836.0938 500.5625,838.1719 500.5625,840.8906 L500.5625,842.0156 C500.5625,844.5938 502.6719,846.4844 505.5625,846.4844 C506.7813,846.4844 507.9375,846.1875 508.6875,845.6406 C509.2656,845.2344 509.5938,844.7813 509.5938,844.3906 C509.5938,843.9375 509.2031,843.5469 508.7344,843.5469 C508.5156,843.5469 508.3125,843.625 508.125,843.8125 C507.6719,844.2969 507.6719,844.2969 507.4844,844.3906 C507.0625,844.6563 506.375,844.7813 505.6094,844.7813 C503.5625,844.7813 502.2656,843.6875 502.2656,841.9844 L502.2656,840.8906 C502.2656,839.1094 503.5156,837.7969 505.25,837.7969 C505.8281,837.7969 506.4375,837.9531 506.9063,838.2031 C507.3906,838.4844 507.5625,838.7031 507.6563,839.1094 C507.7188,839.5156 507.75,839.6406 507.8906,839.7656 C508.0313,839.9063 508.2656,840.0156 508.4844,840.0156 C508.75,840.0156 509.0156,839.875 509.1875,839.6563 C509.2969,839.5 509.3281,839.3125 509.3281,838.8906 L509.3281,837.4688 C509.3281,837.0313 509.3125,836.9063 509.2188,836.75 C509.0625,836.4844 508.7813,836.3438 508.4844,836.3438 C508.1875,836.3438 507.9844,836.4375 507.7656,836.75 L507.5938,836.6719 Z " fill="#000000"/><ellipse cx="530.75" cy="840.5" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacing" textLength="118" x="536.75" y="845.1543">StringStringListener</text><line style="stroke:#A80036;stroke-width:1.5;" x1="395.5" x2="752.5" y1="857" y2="857"/><ellipse cx="405.5" cy="868" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="333" x="414.5" y="871.2104">void receiveMessageFromExampleTopic (String message)</text><!--MD5=[299197fc03270f06f5d2a28f36d1e51d]
class StringStringWithFilterListener--><rect codeLine="129" fill="#FEFECE" filter="url(#f1gtkmahyy9zwr)" height="52.8047" id="StringStringWithFilterListener" style="stroke:#A80036;stroke-width:1.5;" width="240" x="789" y="825"/><ellipse cx="814.35" cy="841" fill="#ADD1B2" rx="11" ry="11" style="stroke:#A80036;stroke-width:1.0;"/><path d="M816.6938,836.6719 C815.7563,836.2344 815.1625,836.0938 814.2875,836.0938 C811.6625,836.0938 809.6625,838.1719 809.6625,840.8906 L809.6625,842.0156 C809.6625,844.5938 811.7719,846.4844 814.6625,846.4844 C815.8813,846.4844 817.0375,846.1875 817.7875,845.6406 C818.3656,845.2344 818.6938,844.7813 818.6938,844.3906 C818.6938,843.9375 818.3031,843.5469 817.8344,843.5469 C817.6156,843.5469 817.4125,843.625 817.225,843.8125 C816.7719,844.2969 816.7719,844.2969 816.5844,844.3906 C816.1625,844.6563 815.475,844.7813 814.7094,844.7813 C812.6625,844.7813 811.3656,843.6875 811.3656,841.9844 L811.3656,840.8906 C811.3656,839.1094 812.6156,837.7969 814.35,837.7969 C814.9281,837.7969 815.5375,837.9531 816.0063,838.2031 C816.4906,838.4844 816.6625,838.7031 816.7563,839.1094 C816.8188,839.5156 816.85,839.6406 816.9906,839.7656 C817.1313,839.9063 817.3656,840.0156 817.5844,840.0156 C817.85,840.0156 818.1156,839.875 818.2875,839.6563 C818.3969,839.5 818.4281,839.3125 818.4281,838.8906 L818.4281,837.4688 C818.4281,837.0313 818.4125,836.9063 818.3188,836.75 C818.1625,836.4844 817.8813,836.3438 817.5844,836.3438 C817.2875,836.3438 817.0844,836.4375 816.8656,836.75 L816.6938,836.6719 Z " fill="#000000"/><ellipse cx="835.65" cy="840.5" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacing" textLength="174" x="841.65" y="845.1543">StringStringWithFilterListener</text><line style="stroke:#A80036;stroke-width:1.5;" x1="790" x2="1028" y1="857" y2="857"/><ellipse cx="800" cy="868" fill="#84BE84" rx="3" ry="3" style="stroke:#038048;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="214" x="809" y="871.2104">void listenWithFilter (String message)</text><!--MD5=[edbb0acea1f82d9a5b3b9ce5853ac9c0]
class ConsumerTest--><rect codeLine="139" fill="#FEFECE" filter="url(#f1gtkmahyy9zwr)" height="188.8516" id="ConsumerTest" style="stroke:#A80036;stroke-width:1.5;" width="400" x="32" y="383.5"/><ellipse cx="178.75" cy="399.5" fill="#ADD1B2" rx="11" ry="11" style="stroke:#A80036;stroke-width:1.0;"/><path d="M181.0938,395.1719 C180.1563,394.7344 179.5625,394.5938 178.6875,394.5938 C176.0625,394.5938 174.0625,396.6719 174.0625,399.3906 L174.0625,400.5156 C174.0625,403.0938 176.1719,404.9844 179.0625,404.9844 C180.2813,404.9844 181.4375,404.6875 182.1875,404.1406 C182.7656,403.7344 183.0938,403.2813 183.0938,402.8906 C183.0938,402.4375 182.7031,402.0469 182.2344,402.0469 C182.0156,402.0469 181.8125,402.125 181.625,402.3125 C181.1719,402.7969 181.1719,402.7969 180.9844,402.8906 C180.5625,403.1563 179.875,403.2813 179.1094,403.2813 C177.0625,403.2813 175.7656,402.1875 175.7656,400.4844 L175.7656,399.3906 C175.7656,397.6094 177.0156,396.2969 178.75,396.2969 C179.3281,396.2969 179.9375,396.4531 180.4063,396.7031 C180.8906,396.9844 181.0625,397.2031 181.1563,397.6094 C181.2188,398.0156 181.25,398.1406 181.3906,398.2656 C181.5313,398.4063 181.7656,398.5156 181.9844,398.5156 C182.25,398.5156 182.5156,398.375 182.6875,398.1563 C182.7969,398 182.8281,397.8125 182.8281,397.3906 L182.8281,395.9688 C182.8281,395.5313 182.8125,395.4063 182.7188,395.25 C182.5625,394.9844 182.2813,394.8438 181.9844,394.8438 C181.6875,394.8438 181.4844,394.9375 181.2656,395.25 L181.0938,395.1719 Z " fill="#000000"/><polygon fill="#4177AF" points="204.25,395,200.25,401,208.25,401" style="stroke:#1963A0;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="12" lengthAdjust="spacing" textLength="87" x="210.25" y="403.6543">ConsumerTest</text><line style="stroke:#A80036;stroke-width:1.5;" x1="33" x2="431" y1="415.5" y2="415.5"/><rect fill="none" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="40" y="423.5"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="265" x="52" y="429.7104">EmbeddedKafkaBroker embeddedKafkaBroker</text><rect fill="none" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="40" y="436.3047"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="205" x="52" y="442.5151">AbstractListener listenerStringString</text><rect fill="none" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="40" y="449.1094"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="233" x="52" y="455.3198">AbstractListener listenerStringStringFilter</text><rect fill="none" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="40" y="461.9141"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="195" x="52" y="468.1245">AbstractListener listenerStringPojo</text><line style="stroke:#A80036;stroke-width:1.5;" x1="33" x2="431" y1="474.7188" y2="474.7188"/><polygon fill="#4177AF" points="43,481.7188,39,487.7188,47,487.7188" style="stroke:#1963A0;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="186" x="52" y="488.9292">void testConsumerStringString ()</text><polygon fill="#4177AF" points="43,494.5234,39,500.5234,47,500.5234" style="stroke:#1963A0;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="267" x="52" y="501.7339">void testConsumerStringStringWithValidFilter ()</text><polygon fill="#4177AF" points="43,507.3281,39,513.3281,47,513.3281" style="stroke:#1963A0;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="277" x="52" y="514.5386">void testConsumerStringStringWithInValidFilter ()</text><polygon fill="#4177AF" points="43,520.1328,39,526.1328,47,526.1328" style="stroke:#1963A0;stroke-width:1.0;"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="176" x="52" y="527.3433">void testConsumerStringPojo ()</text><rect fill="#F24D5C" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="40" y="533.9375"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="321" x="52" y="540.1479">Producer&lt;String String&gt; configureProducerStringString ()</text><rect fill="#F24D5C" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="40" y="546.7422"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="374" x="52" y="552.9526">Producer&lt;String String&gt; configureProducerStringStringWithFilter ()</text><rect fill="#F24D5C" height="6" style="stroke:#C82930;stroke-width:1.0;" width="6" x="40" y="559.5469"/><text fill="#000000" font-family="sans-serif" font-size="11" lengthAdjust="spacing" textLength="349" x="52" y="565.7573">Producer&lt;String MessageLog&gt; configureProducerStringPojo ()</text><!--MD5=[9d5f8beef32a22d50ddbe8ff3c7e0aad]
reverse link ListenableFutureCallback to CustomPojoKafkaListener--><path d="M1914.95,118.182 C1936.26,144.378 1967.11,182.314 1990.73,211.357 " fill="none" id="ListenableFutureCallback-backto-CustomPojoKafkaListener" style="stroke:#A80036;stroke-width:1.0;stroke-dasharray:7.0,7.0;"/><polygon fill="none" points="1909.41,122.457,1902.22,102.524,1920.27,113.624,1909.41,122.457" style="stroke:#A80036;stroke-width:1.0;"/><!--MD5=[41daa5eba094e41d6d99dddee87ba9a6]
reverse link CustomPojoKafkaListener to MessageLog--><path codeLine="46" d="M2152.8,301.283 C2174.95,307.636 2197.96,313.259 2220,317 C2280.72,327.303 2717.78,308.856 2774,334 C2825.76,357.151 2867.44,410.134 2890.43,444.702 " fill="none" id="CustomPojoKafkaListener-backto-MessageLog" style="stroke:#A80036;stroke-width:1.0;"/><polygon fill="none" points="2140.23,297.577,2144.85,303.1138,2151.7378,300.9787,2147.1178,295.4419,2140.23,297.577" style="stroke:#A80036;stroke-width:1.0;"/><!--MD5=[66c0288c2ec90a0fc8bf50bfe2953d02]
reverse link ListenableFutureCallback to CustomStringKafkaListener--><path d="M1942.5,110.451 C1960.26,117.81 1980.33,125.682 1999,132 C2095.41,164.629 2122.81,161.774 2220,192 C2239.22,197.977 2259.48,204.702 2279.14,211.452 " fill="none" id="ListenableFutureCallback-backto-CustomStringKafkaListener" style="stroke:#A80036;stroke-width:1.0;stroke-dasharray:7.0,7.0;"/><polygon fill="none" points="1939.66,116.851,1923.96,102.619,1945.11,103.954,1939.66,116.851" style="stroke:#A80036;stroke-width:1.0;"/><!--MD5=[d30a6f4c9732f1286a7e2185313ffe0f]
reverse link CommandLineRunner to Main--><path d="M1664,122.673 C1664,142.743 1664,168.476 1664,191.802 " fill="none" id="CommandLineRunner-backto-Main" style="stroke:#A80036;stroke-width:1.0;stroke-dasharray:7.0,7.0;"/><polygon fill="none" points="1657,122.524,1664,102.524,1671,122.524,1657,122.524" style="stroke:#A80036;stroke-width:1.0;"/><!--MD5=[8eae03222806184d7cbc0c5ade92e010]
reverse link Main to ProducerMessageService--><path codeLine="61" d="M1825.42,316.051 C1826.95,316.379 1828.48,316.695 1830,317 C1921.59,335.341 2159.96,309.154 2250,334 C2316.26,352.283 2384.25,389.839 2434.5,421.876 " fill="none" id="Main-backto-ProducerMessageService" style="stroke:#A80036;stroke-width:1.0;"/><polygon fill="none" points="1812.67,313.086,1817.6088,318.3404,1824.3585,315.8024,1819.4197,310.548,1812.67,313.086" style="stroke:#A80036;stroke-width:1.0;"/><!--MD5=[c11d2ed7c20ce692e0ec43255c0ff9d3]
reverse link ProducerMessageService to KafkaTemplate--><path codeLine="70" d="M2443.9,543.188 C2390.77,592.533 2321.38,656.99 2290.3,685.863 " fill="none" id="ProducerMessageService-backto-KafkaTemplate" style="stroke:#A80036;stroke-width:1.0;"/><polygon fill="none" points="2453.61,534.162,2446.4922,535.3183,2444.8219,542.3333,2451.9397,541.177,2453.61,534.162" style="stroke:#A80036;stroke-width:1.0;"/><!--MD5=[fbbf9a133c632c6b233f559e31beb225]
reverse link ProducerTest to EmbeddedKafkaBroker--><path codeLine="82" d="M1896.26,559.576 C1815.71,606.022 1721.81,660.17 1677.16,685.915 " fill="none" id="ProducerTest-backto-EmbeddedKafkaBroker" style="stroke:#A80036;stroke-width:1.0;"/><polygon fill="none" points="1907.53,553.077,1900.3344,552.6048,1897.1309,559.0653,1904.3266,559.5375,1907.53,553.077" style="stroke:#A80036;stroke-width:1.0;"/><!--MD5=[e5b1194f771b06a68cc1a08fde9a4c8f]
reverse link ProducerTest to KafkaTemplate--><path codeLine="83" d="M2125.28,562.275 C2174.28,607.987 2230.48,660.402 2257.62,685.724 " fill="none" id="ProducerTest-backto-KafkaTemplate" style="stroke:#A80036;stroke-width:1.0;"/><polygon fill="none" points="2115.58,553.231,2117.2373,560.2491,2124.3529,561.4185,2122.6956,554.4005,2115.58,553.231" style="stroke:#A80036;stroke-width:1.0;"/><!--MD5=[fce8638184f06b063518a03a7db32cb6]
reverse link SimpleKafkaTest to EmbeddedKafkaBroker--><path codeLine="93" d="M1651,553.647 C1651,601.158 1651,658.658 1651,685.629 " fill="none" id="SimpleKafkaTest-backto-EmbeddedKafkaBroker" style="stroke:#A80036;stroke-width:1.0;"/><polygon fill="none" points="1651,540.545,1647,546.545,1651,552.545,1655,546.545,1651,540.545" style="stroke:#A80036;stroke-width:1.0;"/><!--MD5=[493cd41d7026260a2b2ec5a4999ecb64]
reverse link AbstractListener to StringPojoListener--><path d="M454,766 C454,766 350.045,800.047 274.109,824.9179 " fill="none" id="AbstractListener-backto-StringPojoListener" style="stroke:#A80036;stroke-width:1.0;"/><!--MD5=[bf358b26dd415f74d576611aeb5e9e22]
reverse link AbstractListener to StringStringListener--><path d="M454,766 C454,766 502.351,800.047 537.67,824.9179 " fill="none" id="AbstractListener-backto-StringStringListener" style="stroke:#A80036;stroke-width:1.0;"/><!--MD5=[6698944ad72dfd39ce38a2293def3822]
reverse link AbstractListener to StringStringWithFilterListener--><path d="M454,766 C454,766 654.056,803.153 788.859,828.1881 " fill="none" id="AbstractListener-backto-StringStringWithFilterListener" style="stroke:#A80036;stroke-width:1.0;"/><!--MD5=[c5642679ffdb00382036e00c68ee3d4a]
reverse link ConsumerTest to EmbeddedKafkaBroker--><path codeLine="153" d="M438.575,576.235 C442.059,577.208 445.536,578.132 449,579 C884.321,688.136 1015.81,556.715 1457,639 C1512.79,649.405 1574.88,671.134 1613.44,685.897 " fill="none" id="ConsumerTest-backto-EmbeddedKafkaBroker" style="stroke:#A80036;stroke-width:1.0;"/><polygon fill="none" points="425.935,572.501,430.556,578.0369,437.4434,575.9006,432.8224,570.3647,425.935,572.501" style="stroke:#A80036;stroke-width:1.0;"/><!--MD5=[22f8459be5ee93f72fbbad27846a44c9]
reverse link ConsumerTest to AbstractListener--><path codeLine="154" d="M319.674,582.53 C335.974,601.777 352.528,621.326 367.365,638.846 " fill="none" id="ConsumerTest-backto-AbstractListener" style="stroke:#A80036;stroke-width:1.0;"/><polygon fill="none" points="311.184,572.505,312.0088,579.6688,318.9387,581.6627,318.1139,574.499,311.184,572.505" style="stroke:#A80036;stroke-width:1.0;"/><!--MD5=[2593ba58baff25885c344744cb0065ab]
@startuml
hide empty members
skinparam groupInheritance 3

package "Commons Module" <<Folder>> #DDDDDD {

+class KafkaTopicConfig{


+  KafkaAdmin kafkaAdmin (String bootstrapAddress)
+  NewTopic topic1 ()
+  NewTopic topic2 ()
}
+class KafkaConstants{
-String DEFAULT_TOPIC
+String KAFKA_TOPIC_STRING_STRING
+String KAFKA_TOPIC_STRING_STRING_WITH_FILTER
+String KAFKA_TOPIC_STRING_POJO
+String KAFKA_GROUP_ID


}
+class MessageLog{
-String message
-LocalDateTime creationTime


}
}

package "Producer Module" <<Folder>> #DDDDDD {

+class KafkaProducerConfig{


+  ProducerFactory<String String> producerFactory (String bootstrapAddress)
+  KafkaTemplate<String String> kafkaTemplate (ProducerFactory<String String> producerFactory)
+  ProducerFactory<String MessageLog> customPojoProducerFactory (String bootstrapAddress)
+  KafkaTemplate<String MessageLog> kafkaTemplateWithCustomPojo (ProducerFactory<String MessageLog> producerFactory)
}
+class CustomPojoKafkaListener implements ListenableFutureCallback{
-MessageLog message

+  void onSuccess (SendResult<String MessageLog> result)
+  void onFailure (Throwable exception)
}
CustomPojoKafkaListener o- - MessageLog
+class CustomStringKafkaListener implements ListenableFutureCallback{
-String message

+  void onSuccess (SendResult<String String> result)
+  void onFailure (Throwable exception)
}
+class Main implements CommandLineRunner{
-ProducerMessageService sendMessageService

+ {static} void main (String args)
+  void run (String args)
-  void sendPojo ()
-  void sendString ()
}
Main o- - ProducerMessageService
+class ProducerMessageService{
-KafkaTemplate<String String> kafkaTemplate
-KafkaTemplate<String MessageLog> kafkaTemplateWithPojo

+  void sendAsynchronousStringMessage (String asynchronousMessage,String topic)
+  void sendAsynchronousPojoMessage (MessageLog customMessage,String topic)
+  void sendSynchronousStringMessage (String synchronousMessage)
}
ProducerMessageService o- - KafkaTemplate
~class ProducerTest{
-EmbeddedKafkaBroker embeddedKafkaBroker
-KafkaTemplate<String String> producerStringString
-KafkaTemplate<String MessageLog> producerStringPojo

~  void testProducerStringString ()
~  void testProducerStringPojo ()
~  void testProducerStringStringFilter ()
-  Consumer<String String> configureConsumerStringString ()
-  Consumer<String MessageLog> configureConsumerStringPojo ()
}
ProducerTest o- - EmbeddedKafkaBroker
ProducerTest o- - KafkaTemplate
~class SimpleKafkaTest{
#{static}String TOPIC
-{static}String KAFKA_GROUP
-EmbeddedKafkaBroker embeddedKafkaBroker

~  void testReceivingKafkaEvents ()
-  Consumer<Integer String> configureConsumer ()
-  Producer<Integer String> configureProducer ()
}
SimpleKafkaTest o- - EmbeddedKafkaBroker

}
package "Consumer Module" <<Folder>> #DDDDDD {

+class KafkaConsumerConfig{
+{static}String STRING_TO_FILTER
-String bootstrapAddress

+  ConsumerFactory<String String> consumerFactory ()
+  ConcurrentKafkaListenerContainerFactory<String String> kafkaListenerContainerFactory (ConsumerFactory<String String> consumerFactory)
+  ConsumerFactory<String String> consumerFactoryWithFilter ()
+  ConcurrentKafkaListenerContainerFactory<String String> kafkaListenerContainerFactoryWithFilter (ConsumerFactory<String String> consumerFactory)
+  ConsumerFactory<String MessageLog> consumerFactoryWithPojo ()
+  ConcurrentKafkaListenerContainerFactory<String MessageLog> kafkaListenerContainerFactoryWithPojo (ConsumerFactory<String MessageLog> consumerFactory)
+  ConcurrentKafkaListenerContainerFactory<String String> filterKafkaListenerContainerFactory (ConsumerFactory<String String> consumerFactoryWithFilter)
+  ConcurrentKafkaListenerContainerFactory<String MessageLog> pojoKafkaListenerContainerFactory (ConsumerFactory<String MessageLog> consumerFactoryWithPojo)
-  RecordFilterStrategy<String String> createCustomRecordFilterStrategy ()
-  Map<String Object> createKafkaProperties ()
}
+abstract  class AbstractListener{
#CountDownLatch latch
#String payload

#  void processMessage (int listenerNumber,String message,String topic)
}
+class StringPojoListener extends AbstractListener{


+  void greetingListener (MessageLog customMessage)
}
+class StringStringListener extends AbstractListener{


+  void receiveMessageFromExampleTopic (String message)
}
+class StringStringWithFilterListener extends AbstractListener{


+  void listenWithFilter (String message)
}
+class Main{


+ {static} void main (String args)
}
~class ConsumerTest{
-EmbeddedKafkaBroker embeddedKafkaBroker
-AbstractListener listenerStringString
-AbstractListener listenerStringStringFilter
-AbstractListener listenerStringPojo

~  void testConsumerStringString ()
~  void testConsumerStringStringWithValidFilter ()
~  void testConsumerStringStringWithInValidFilter ()
~  void testConsumerStringPojo ()
-  Producer<String String> configureProducerStringString ()
-  Producer<String String> configureProducerStringStringWithFilter ()
-  Producer<String MessageLog> configureProducerStringPojo ()
}
ConsumerTest o- - EmbeddedKafkaBroker
ConsumerTest o- - AbstractListener

}
@enduml

PlantUML version 1.2022.2beta1(Unknown compile time)
(GPL source distribution)
Java Runtime: Java(TM) SE Runtime Environment
JVM: Java HotSpot(TM) 64-Bit Server VM
Default Encoding: UTF-8
Language: en
Country: US
--></g></svg>