Kafka

Introduction

Message broker with Kafka.

Properties

id

string

Required

displayName

string

description

string

version

string

locked

boolean

links

ComponentLink[]

namespace

string

kafkaTopics

KafkaTopic[]

Required

kafkaUsers

KafkaUser[]

Required

Arguments

KafkaCluster.builder()
  .withId("azure-kafka")
  .withDescription("Kafka for Azure")
  .withDisplayName("AzureKafka #1")
  .withNamespace("namespace")
  .withLink(getComponentLink())
  .withKafkaTopics(List.of(
          KafkaTopic.builder().withId("topic").withDisplayName("kafka-topic").build(),
          KafkaTopic.builder().withId("topic-2").withDisplayName("kafka-topic-2").build()))
  .withKafkaUsers(List.of(
          KafkaUser.builder().withId("user-1").withDisplayName("kafka-user").withTopicReadACL("svcName").build(),
          KafkaUser.builder().withId("user-2").withDisplayName("kafka-user-2").build()))
  .build()

Examples

Azure

AzureKubernetesService.builder()
    .withId("aks-1")
    .withDescription("Test AKS cluster")
    .withDisplayName("AKS #1")
    .region(EUROPE_WEST)
    .withMessageBroker(KafkaCluster.builder()
        .withId("azure-kafka")
        .withDescription("Kafka for Azure")
        .withDisplayName("AzureKafka #1")
        .withNamespace("namespace")
        .withLink(getComponentLink())
        .withKafkaTopics(List.of(
                KafkaTopic.builder().withId("topic").withDisplayName("kafka-topic").build(),
                KafkaTopic.builder().withId("topic-2").withDisplayName("kafka-topic-2").build()))
        .withKafkaUsers(List.of(
                KafkaUser.builder().withId("user-1").withDisplayName("kafka-user").withTopicReadACL("svcName").build(),
                KafkaUser.builder().withId("user-2").withDisplayName("kafka-user-2").build()))
        .build())
    .build();