IBM Sterling B2B: Configuring SB2Bi to use Kafka

1) Deploy Kafka: Deploy Kafka as Container

2) Using Kwol create topics

• sb2b-kfk-inbound
• sb2b-kfk-outbound

Create a Business Process to put a file in Kafka

• BootStrapServers: Server:Port, same as variable. KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://localhost:29092
• KafkaClientAdapter: KafkaClientAdapter
• SecurityAction: security action same as variable. KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://localhost:29092
• GroupId:
• Topic: topic name that i create previously - sb2b-kfk-outbound

<process name="Demo_Kafka_Producer">
  <sequence>
    <operation name="Kafka Client Begin Session Service">
       <participant name='KafkaBeginSessionService'/>
       <output message="xout">
          <assign to='Action'>put</assign>
          <assign to='BootStrapServers'>localhost:29092</assign>
          <assign to='KafkaClientAdapter'>KafkaClientAdapter</assign>
          <assign to='SecurityAction'>PLAINTEXT</assign>
          <assign to='GroupId'>demo-kafka-producer-001</assign>
          <assign to='ProducerConfig'>buffer.memory=102400;compression.type=gzip</assign>
          <assign to='.' from='PrimaryDocument'/>
       </output>
       <input message="xin">
          <assign to="KafkaBeginSessionServiceResults" from="*"/>
       </input>
    </operation>

    <operation name="Kafka Client Producer Service">
       <participant name="KafkaProducerService"/>
       <output message="xout">
          <assign to="SessionID" from="//KafkaBeginSessionServiceResults/SessionID/text()"/>
          <assign to="KafkaClientAdapter" from="//KafkaBeginSessionServiceResults/KafkaClientAdapter/text()"/>
          <assign to='Topic'>sb2b-kfk-outbound</assign>
          <assign to='.' from='PrimaryDocument'/>
       </output>
       <input message="xin">
          <assign to="." from="*"/>
       </input>
    </operation>

    <operation name="Kafka Client End Session Service">
       <participant name='KafkaEndSessionService'/>
       <output message="xout">
          <assign to="SessionID" from="//KafkaBeginSessionServiceResults/SessionID/text()"/>
          <assign to="KafkaClientAdapter" from="//KafkaBeginSessionServiceResults/KafkaClientAdapter/text()"/>
          <assign to='Action'>put</assign>
       </output>
       <input message="xin">
          <assign to="." from="*"/>
       </input>
    </operation>
  </sequence>
</process>