Kafka Begin Session Service

<process name="KafkaExample">
  <sequence>
    <operation name="Kafka Begin Session Service">
      <participant name=" KafkaBeginSessionService "/>
<output message="xout">        
  <assign to=" KafkaClientAdapter "> KafkaClientAdapter </assign>
        <assign to=" Action">put</assign>
        <assign to='BootStrapServers'>//CLUSTERIP1:PORT1,CLUSTERIP2:PORT2,...</assign>
	<assign to='KafkaClientAdapter'>//Mention the kafka adapter to invoke or ignore the entry</assign>
	<assign to='SecurityAction'>//Any Possible Action(PLAINTEXT/SASL_PLAINTEXT/SSL/SASL_SSL)</assign>
	<!-- Add below entries for SASL -->
	<assign to='SASLMechanism'>//SASLMechanism(SCRAM-SHA-512/PLAINLOGIN etc)</assign>
	<assign to='SASLJaasConfig'>//Path to jaas conf file</assign>
	<!-- End of SASL configuration -->
	<!-- Add below entries for SSL -->
	<assign to='TrustStorePath'>//Path to truststore</assign>
	<assign to='TrustStorePassword'>//Trusstore Password</assign>
	<!-- Add below entries for 2 way SSL-->
	<assign to='KeyStorePath'>//Path to Keystore</assign>
	<assign to='KeyStorePassword'>//Keystore Password</assign>
	<!-- End of entries for 2 way SSL-->
	<!-- End of entries for SSL configuration -->
	<assign to='ProducerConfig'>//Key value pairs separated by ;</assign>
	<assign to='KeySerializer'>//Specifiy the key serializer class</assign>
	<assign to='ValueSerializer'>//Specify the value serializer class</assign>
	<assign to='.' from='PrimaryDocument'/>      
</output>
      <input message="inmsg">
        <assign to="." from="*"/>      </input>
    </operation> 
[[Producer/Consumer session here]] 
[[End session here]] 
</process>