View source for 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

[[File:sb2b-kafka-kowl-create-topic.png]]


= Put and Get Files from Kafka =

* [[IBM Sterling B2B: Create a Business Process to put a file in Kafka]]

* [https://github.com/ebasso/sterling-b2b-samples/tree/master/business-process/using-kafka | Create a Business Process to Consume (get) a file from Kafka]

= Create a Custom Protocol in SFG to use with Kafka =

* https://github.com/ebasso/sterling-b2b-samples/tree/master/filegateway-scenarios/route-via-kafka


= Configure Kafka Consumer Streams Adapter =

The Kafka Consumer Streams Adapter connects with a Kafka queue to pull messages continuously.

* '''Important''': key must be the filename of file.

[[File:Sb2b-kdk-key-value.png]]


== Configuring the Adapter ==

1) To Create a new Adapter, open Dashboard > Deployment > Configuration

2) Search for Kafka Consumer Stream Service, and click '''Next'''

[[File:sb2b-kafka-setup-01.png]]

3) Define a name and description, and click '''Next'''

[[File:sb2b-kafka-setup-02.png]]

4) Define Bootstrap Server and Topic, and click '''Next'''

[[File:sb2b-kafka-setup-03.png]]

5) In Deserializer, click '''Next'''

[[File:sb2b-kafka-setup-04.png]]

6) In properties, click '''Next'''

[[File:sb2b-kafka-setup-05.png]]

7) Choose to write the file to a Mailbox, and click '''Next'''

[[File:sb2b-kafka-setup-06.png]]

8) Define a Mailbox to write the file , and click '''Next'''

[[File:sb2b-kafka-setup-07.png]]

9) Click '''Next''' and '''Finish'''

Now this adapter will use BP '''KafkaStreamServiceMailbox''' to monitor topics and write to mailboxes.

 <process name="KafkaStreamServiceMailbox">
  <sequence>
    <operation name="SetUserContext">
      <participant name="SetUserTokenServiceKafka"/>
      <output message="xin">
        <assign to="USER_TOKEN" from="//MAILBOXUSER/text()"/>
      </output>
      <input message="xout">
        <assign to="." from="*"/>
      </input>
    </operation>
    <operation name="Mailbox Add Service">
      <participant name="MailboxAdd"/>
      <output message="MailboxAddServiceTypeInputMessage">
        <assign to="." from="*"/>
        <assign to="Extractable">Yes</assign>
        <assign to="MailboxPath" from="//MAILBOXPATH/text()"/>
        <assign to="DocumentId" from="/PrimaryDocument/@SCIObjectID"/>
        <assign to="MessageName" from="//Files/Documents/Document/Name/text()"/>
        <assign to="UseGlobalMailboxes" from="//GLOBALMAILBOX/text()"/>
      </output>
      <input message="inmsg">
        <assign to="MailboxAddResult" from="*"/>
      </input>
    </operation>
  </sequence>
 </process>

= Check Topics and messages =

To check Topics and messages i using Kowl

[[File: sb2b-kfk-inbound-01.png]]

= Ver também =

[[Category:Kafka]]
[[Category:IBM Sterling]]
[[Category:IBM Sterling B2B]]
[[Category:File Gateway]]
[[Category:SFG]]