Posts

Showing posts with the label kafka

OIC Kafka Adapter - Trigger

Image
The November release for the Oracle Integration Cloud (OIC) delivered the Trigger capability for the Kafka Adapter. Up until now we could only use Scheduled Integrations to consume messages. Now, we can make use of the App Driven Integration which will be triggered whenever new messages arrive to the subscribed Kafka topic. It's noteworthy to mention that this feature requires the connectivity agent in order to run. See the official release notes here : If you are new to the OIC Kafka Adap ter, start with this post , where I covered Kafka installation, OIC prerequisites and the  consumer/producer capabilities. Now I am going to cover the Kafka Adapter as a Trigger. In my Kafka server I will create a new Topic for this specific use case. Create a new Kafka topic Using the command line: ./kafka-topics.sh --create --bootstrap-server localhost:9092 -- replication-factor 1 --partitions 1 --topic TopicTrigger Create a new Connection The connection from the previous post was only for Invo...

Kafka Adapter for OIC

Image
This article was originally published in the Oracle Integration Blog. The Kafka adapter for Oracle Integration Cloud came out earlier this month, and it was one of the most anticipated releases.     So what is Kafka? You can find all about it on https://kafka.apache.org/ , but in a nutshell: Apache Kafka is a distributed streaming platform with three main key capabilities: Publish and subscribe to streams of records. Store streams of records in a fault-tolerant durable way. Process streams of records as they occur. Kafka is run as a cluster on one or more servers that can span multiple data centres. The Kafka cluster stores streams of records in categories called topics, and each record consists of a key, a value, and a timestamp.   Kafka Adapter Capabilities The Apache Kafka Adapter enables you to create an integration in Oracle Integration that connects to an Apache Kafka me...