レッドハットのプロダクト（Vol.68記載）

著者：小杉研太

前回（第3回）に引き続き、アプリやデータの連携を実現するためのミドルウエア製品「Red Hat Integration」を紹介します。第4回はRed Hat Integrationに含まれる「Red Hat AMQ」と「Red Hat Fuse」のアップストリームとなる「Strimzi」と「Apache Camel」について触れます。

シェルスクリプトマガジン Vol.68は以下のリンク先でご購入できます。

図17　KafkaとSlackを統合できるコード

FromKafkaToSlack.java
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.slack.SlackComponent;

public class FromKafkaToSlack extends RouteBuilder {

    @Override
    public void configure() throws Exception {
        final SlackComponent slackComponent = (SlackComponent) this.getContext().getComponent("slack");
        slackComponent.setWebhookUrl(Webhook URL);

        from("kafka:my-topic?brokers=my-cluster-kafka-bootstrap:9092")
            .routeId("from-kafka-to-slack")
            .to("slack:#my-kafka-project");
    }
}

FromKafkaToSlack.java

import org.apache.camel.builder.RouteBuilder;

import org.apache.camel.component.slack.SlackComponent;

public class FromKafkaToSlack extends RouteBuilder {

@Override

public void configure() throws Exception {

final SlackComponent slackComponent = (SlackComponent) this.getContext().getComponent("slack");

slackComponent.setWebhookUrl(Webhook URL);

from("kafka:my-topic?brokers=my-cluster-kafka-bootstrap:9092")

.routeId("from-kafka-to-slack")

.to("slack:#my-kafka-project");

}