IBM Sterling B2B: Configuring SB2Bi to use Kafka: Difference between revisions
No edit summary |
No edit summary |
||
Line 9: | Line 9: | ||
= Create a BP to put a file in Kafka = | |||
<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> | |||
= Ver também = | = Ver também = |
Revision as of 18:26, 30 October 2023
1) Deploy Kafka: Deploy Kafka as Container
2) Using Kwol create topics
- sb2b-kfk-inbound
- sb2b-kfk-outbound
Create a BP to put a file in Kafka
<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>