Strimzi - Apache Kafka on Kubernetes supports a kafka bridge to allow applications to connect to and use Kafka via HTTP. This task is to investigate whether this is a feasible alternative to MR.

Notes:

1. Parallel deploy required setup below
2. Bridge is dependent on Cluster Operator
3. Strimzi bridge lacks ability to create a Topic and mirror maker

 

Strimzi Bridge Deploy:

wget https://github.com/strimzi/strimzi-kafka-operator/releases/download/0.24.0/strimzi-0.24.0.tar.gz

tar -xvf strimzi-0.24.0.tar.gz

sed -i 's/namespace: ./namespace: onap/' strimzi-0.24.0/install/cluster-operator/*RoleBinding.yaml

kubectl create -f strimzi-0.24.0/install/cluster-operator -n onap

echo -n admin_secret > MY-PASSWORD.txt

kubectl create secret generic adminsecret --from-file=MY-PASSWORD-FIELD-NAME=./MY-PASSWORD.txt -n onap

vim strimzi_bridge.yaml

paste

apiVersion: kafka.strimzi.io/v1beta2

kind: KafkaBridge

metadata:

  name: my-bridge

  namespace: onap

spec:

  authentication:

    type: plain

    username: admin

    passwordSecret:

      secretName: adminsecret

      password: MY-PASSWORD-FIELD-NAME

  producer:

    config:

      sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username=admin password=admin_secret

      sasl.mechanism: PLAIN

  consumer:

    config:

      sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username=admin password=admin_secret

      sasl.mechanism: PLAIN

  replicas: 1

  bootstrapServers: message-router-kafka-0:9091,message-router-kafka-1:9091,message-router-kafka-2:9091

  http:

    port: 8080

kubectl apply -f strimzi_bridge.yaml -n onap

kubectl -n onap expose svc my-bridge-bridge-service --name=xstrimzi-bridge --type=NodePort