Chapter 3. Installing Service Registry

Procedure

1. If you do not already have AMQ Streams installed, install AMQ Streams on your OpenShift cluster. For example, enter the following command from your AMQ Streams download directory:

   oc apply -f install/cluster-operator/

   Copy to Clipboard Toggle word wrap

2. If you do not already have a Kafka cluster set up, create a new Kafka cluster with AMQ Streams. For example:

   $ cat << EOF | oc create -f -
   apiVersion: kafka.strimzi.io/v1beta1
   kind: Kafka
   metadata:
    name: my-cluster
   spec:
    kafka:
      replicas: 3
      listeners:
        external:
          type: route
      storage:
        type: ephemeral
    zookeeper:
      replicas: 3
      storage:
        type: ephemeral
    entityOperator:
      topicOperator: {}
   EOF

   Copy to Clipboard Toggle word wrap

   This simple example creates a cluster with 3 Zookeeper nodes and 3 Kafka nodes using ephemeral storage. All data is lost when the Pods are no longer running on OpenShift.

3. Create the required storage-topic to store Service Registry artifacts in AMQ Streams. For example:

   $ cat << EOF | oc create -f -
   apiVersion: kafka.strimzi.io/v1beta1
   kind: KafkaTopic
   metadata:
     name: storage-topic
     labels:
       strimzi.io/cluster: my-cluster
   spec:
     partitions: 3
     replicas: 3
     config:
       cleanup.policy: compact
   EOF

   Copy to Clipboard Toggle word wrap

4. Create the required global-id-topic to store Service Registry global IDs in AMQ Streams. For example:

   $ cat << EOF | oc create -f -
   apiVersion: kafka.strimzi.io/v1beta1
   kind: KafkaTopic
   metadata:
     name: global-id-topic
     labels:
       strimzi.io/cluster: my-cluster
   spec:
     partitions: 3
     replicas: 3
     config:
       cleanup.policy: compact
   EOF

   Copy to Clipboard Toggle word wrap

Procedure

1. Get the Service Registry OpenShift template.

2. Enter the following command to get the name of the Kafka bootstrap service running in AMQ Streams on your OpenShift cluster:

   $ oc get services | grep .*kafka-bootstrap

   Copy to Clipboard Toggle word wrap

3. Create a new OpenShift application using the oc new-app command. For example:

   $ oc new-app service-registry-template.yml \
      -p KAFKA_BOOTSTRAP_SERVERS=my-cluster-kafka-bootstrap:9092 \
      -p REGISTRY_ROUTE=my-cluster-service-registry-myproject.example.com \
      -p APPLICATION_ID=my-kafka-streams-app

   Copy to Clipboard Toggle word wrap

   You must specify the following arguments:

   • service-registry-template.yml: The OpenShift template file for Service Registry.
   • KAFKA_BOOTSTRAP_SERVERS: The name of the Kafka bootstrap service on your OpenShift cluster, followed by the Kafka broker port. For example: my-cluster-kafka-bootstrap:9092.
   • REGISTRY_ROUTE: The name of the OpenShift route to expose Service Registry, which is based on your OpenShift cluster environment. For example: my-cluster-service-registry-myproject.example.com.

   • APPLICATION_ID: The name of your AMQ Streams application. For example: my-kafka-streams-app.

     You can also specify the following environment variables using the -e option:

   • APPLICATION_SERVER_HOST: The IP address of your Kafka Streams application server host, which is required in a multi-node Kafka configuration. Defaults to $(POD_IP).
   • APPLICATION_SERVER_PORT: The port number of your Kafka Streams application server, which is required in a multi-node Kafka configuration. Defaults to 9000.

4. Verify the command output when complete. For example:

   Deploying template "myproject/service-registry" for "service-registry-template.yml" to project myproject
   
    service-registry
    ---------
    Congratulations on deploying Service Registry into OpenShift!
   
    All components have been deployed and configured.
   
     * With parameters:
       * Registry Route Name=my-cluster-service-registry-myproject.example.com
       * Registry Max Memory Limit=1300Mi
       * Registry Memory Requests=600Mi
       * Registry Max CPU Limit=1
       * Registry CPU Requests=100m
       * Kafka Bootstrap Servers=my-cluster-kafka-bootstrap:9092
       * Kafka Application ID=my-kafka-streams-app
   
   --> Creating resources ...
       imagestream.image.openshift.io "registry" created
       service "service-registry" created
       deploymentconfig.apps.openshift.io "service-registry" created
       route.route.openshift.io "service-registry" created
   --> Success
       Access your application via route 'my-cluster-service-registry-myproject.example.com'

   Copy to Clipboard Toggle word wrap
5. Enter oc status to view your Service Registry installation on OpenShift.