samples/

README

Getting Started

This document is aimed to provide an example about how to connect to the kafka and consume the message which is generated by the regional hub. In this way, you can get the message from ACM and push to your owned system.

• consumer: create a separate consumer which can receive message from the regional hubs.

Prerequisites

These instructions assume:

• You need to have a global hub setup successfully. You can choose to setup a global hub environment on the OCP. If you do not have OCP, you can also run make e2e-setup-start to create a local one in your linux machine.

Set environment variables.

export KUBECONFIG=</path/to/global_hub_cluster/kubeconfig>
export SECRET_NAMESPACE=<transport-secret-namespace> # default SECRET_NAMESPACE=open-cluster-management
export SECRET_NAME=<transport-secret-name> # default SECRET_NAME=multicluster-global-hub-transport

Producer and Consumer from different clients

• confluentinc/confluent-kafka-go
• Shopify/sarama
• cloudevents/sdk-go