AMQ Broker/AMQ Streams Demo

Demo showing Kafka and Artemis on top of OpenShift.

Pre-req

For this demonstration, we will need:

• OpenShift 4.8.x

AMQ Broker Demo (Artemis)

Creating AMQ Broker project

Deploying AMQ Broker Operator

Switch to developer console

We should see the container Operator

Deploying AMQ Broker

apiVersion: broker.amq.io/v2alpha4
kind: ActiveMQArtemis
metadata:
  name: amq-broker
  application: amq-broker-app
  namespace: amq-broker-demo
spec:
  deploymentPlan:
    size: 2
    persistenceEnabled: false
    requireLogin: false
    messageMigration: false
    managementRBACEnabled: true
    journalType: nio
    jolokiaAgentEnabled: false
    image: placeholder
  acceptors:
  - name: all
    protocols: all
    port: 61617

Deploying producer and consumer

Producer

Right click on topology page

We can check the logs to see if the producer app is working properly.

Consumer

Right click on topology page

We can check the logs to see if the consumer app is working properly.

Camel K Demo

Deploying Camel K Operator

Deploying Camel K integration

Create a new file AMQBrokerIntegration.java with the following content:

// camel-k: dependency=camel-activemq

import org.apache.camel.builder.RouteBuilder;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.camel.BindToRegistry;

public class AMQBrokerIntegration extends RouteBuilder {
    @BindToRegistry
    public ActiveMQConnectionFactory registerActiveMQConnectionFactory() {
        System.out.println("ActiveMQ Listener: STARTING...");
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
        connectionFactory.setBrokerURL("tcp://ex-aao-hdls-svc:61617");
        connectionFactory.setUserName("admin");
        connectionFactory.setPassword("redhat");
        connectionFactory.setUseAsyncSend(false);
        connectionFactory.setClientID("Message Topic");
        connectionFactory.setConnectResponseTimeout(300);
        System.out.println("ActiveMQ Listener: STARTED");
        return connectionFactory;
    }

    @Override
    public void configure() throws Exception {
      from("activemq:topic:topic.prices")
        .log("body = ${body}")
        ;
    }
}

Now run it:

oc project amq-broker-demo
kamel run AMQBrokerIntegration.java --dev

We can find the link to download the kamel command line on the top right help icon.

Now we should see the logging of our camel route.

AMQ Streams Demo (Kafka)

kubectl -n amq-streams-demo run kafka-producer-topic1 -it --image=quay.io/strimzi/kafka:0.25.0-kafka-2.7.0 --rm=true --restart=Never — bin/kafka-console-producer.sh --broker-list my-cluster-kafka-bootstrap.amq-streams-demo.svc:9092 --topic my-topic