Creating a New Custom BusinessEvents Channel
You can use the custom channel API to create a custom channel according to your requirement for your project.
The Java API for custom channel (com.tibco.be.custom.channel package) is bundled with TIBCO BusinessEvents. For more information about the classes in the
com.tibco.be.custom.channel package see
Java API Reference.
Procedure
Sample Kafka Channel Drivers.xml File
The following sample code is of the
drivers.xml file for the Kafka channel example:
<?xml version="1.0" encoding="UTF-8"?> <drivers> <driver> <type>Kafka</type> <label>Kafka</label> <class>com.tibco.be.custom.channel.kafka.KafkaDriver</class> <description>Apache Kafka is an open-source message broker project developed by the Apache Software Foundation written in Scala. The project aims to provide a unified, high-throughput, low-latency platform for handling real-time data feeds.</description> <version>1.0.0.0</version> <properties> <property name="BootstrapServers" type="String" default="localhost:9095"/> </properties> <destinations> <property name="GroupID" type="String" default="kafka_group"/> <property name="ClientID" type="String" default="1"/> <property name="Topic" type="String" default="ktopic"/> <property name="Threads" type="Integer" default="1"/> <property name="PollInterval" type="Integer" default="100"/> </destinations> <serializers userdefined="true"> <serializer type="Map" class="com.tibco.be.custom.channel.kafka.serializer.KafkaEventSerializer"/> </serializers> </driver> </drivers>
Copyright © TIBCO Software Inc. All rights reserved.