Oktatóanyag: Apache Kafka-szolgáltatás létrehozása és használata fejlesztéshez

Cikk
07/03/2024

Az Azure Container Apps lehetővé teszi a fejlesztési és éles szintű szolgáltatásokhoz való csatlakozást, hogy számos különféle funkciót biztosítson az alkalmazások számára.

Ebben az oktatóanyagban megismerheti egy fejlesztési Apache Kafka-szolgáltatás létrehozását és használatát.

Ebben az oktatóanyagban az Azure CLI-parancsok és a Bicep-sablontöredékek szerepelnek. A Bicep használata esetén az összes töredék hozzáadható egyetlen Bicep-fájlhoz, és egyszerre üzembe helyezheti a sablont.

Container Apps-környezet létrehozása a szolgáltatás és a tárolóalkalmazás üzembe helyezéséhez
Apache Kafka-szolgáltatás létrehozása
Parancssori alkalmazás beállítása a dev Apache Kafka szolgáltatás használatára
Kafka-ui-alkalmazás üzembe helyezése az alkalmazásadatok megtekintéséhez
Végleges bicep-sablon fordítása az összes erőforrás konzisztens és kiszámítható sablontelepítéssel történő üzembe helyezéséhez
azd Sablon használata az összes erőforrás egyetlen parancs üzembe helyezéséhez

Előfeltételek

Telepítse az Azure CLI-t.
Nem kötelező: Azure Developer CLI az AZD-utasítások követéséhez.

Feljegyzés

Egy parancs üzembe helyezéséhez ugorjon az utolsó azd sablonlépésre.

Beállítás

Definiáljon változókat a közös értékekhez.
- Erősen megüt
- Bicep
- azd
```
RESOURCE_GROUP="kafka-dev"
LOCATION="northcentralus"
ENVIRONMENT="aca-env"
KAFKA_SVC="kafka01"
KAFKA_CLI_APP="kafka-cli-app"
KAFKA_UI_APP="kafka-ui-app"
```
Az alábbi változók lehetővé teszik a CLI használatát a Bicep-sablon üzembe helyezéséhez.
```
RESOURCE_GROUP="kafka-dev"
LOCATION="northcentralus"
```
A Bicep esetében először hozzon létre egy nevű kafka-dev.bicepfájlt, majd adjon hozzá paramétereket az alábbi alapértelmezett értékekkel.
```
targetScope = 'resourceGroup'
param location string = resourceGroup().location
param appEnvironmentName string = 'aca-env'
param kafkaSvcName string = 'kafka01'
param kafkaCliAppName string = 'kafka-cli-app'
param kafkaUiAppName string = 'kafka-ui'
```
A bicep-sablon bármely fázisban történő üzembe helyezésekor használhatja a az deployment group create parancsot.
```
az deployment group create -g $RESOURCE_GROUP \
    --query 'properties.outputs.*.value' \
    --template-file kafka-dev.bicep
```
Adja meg a kezdeti változókat.
```
AZURE_ENV_NAME="azd-kafka-dev"
LOCATION="northcentralus"
```
Az értékekkel inicializálhat egy minimális azd sablont.
```
azd init \
    --environment "$AZURE_ENV_NAME" \
    --location "$LOCATION" \
    --no-prompt
```
Feljegyzés

AZURE_ENV_NAME eltér a Container App-környezet nevétől. Ebben a kontextusban AZURE_ENV_NAME azd a sablon összes erőforrása szerepel. Ezek az erőforrások közé tartoznak a Container Appshez nem társított erőforrások. Egy másik nevet hoz létre a Container Apps-környezethez.

Ezután hozzon létre infra/main.bicep és definiáljon paramétereket későbbi használatra.
```
param appEnvironmentName string = 'aca-env'
param kafkaSvcName string = 'kafka01'
param kafkaCliAppName string = 'kafka-cli-app'
param kafkaUiAppName string = 'kafka-ui'
```
Bejelentkezik az Azure-ba.
```
az login
```
Frissítse a parancssori felületet a legújabb verzióra.
```
az upgrade
```
Frissítse a Bicep-et a legújabb verzióra.
```
az bicep upgrade
```

Adja hozzá a bővítményt containerapp .

az extension add --name containerapp --upgrade

Regisztrálja a szükséges névtereket.

az provider register --namespace Microsoft.App

az provider register --namespace Microsoft.OperationalInsights

Container Apps-környezet létrehozása

Hozzon létre egy erőforráscsoportot.
- Erősen megüt
- Bicep
- azd
```
az group create \
    --name "$RESOURCE_GROUP" \
    --location "$LOCATION"
```
```
az group create \
    --name "$RESOURCE_GROUP" \
    --location "$LOCATION"
```
Nincs szükség speciális beállításra az erőforráscsoportok kezeléséhez a következőben azd: . A azd parancs lekéri az erőforráscsoportot az AZURE_ENV_NAME/--environment értékből.

A minimális sablont a up paranccsal tesztelheti.
```
azd up
```
A parancs futtatása üres erőforráscsoportot hoz létre.

Hozzon létre egy Container Apps-környezetet.

az containerapp env create \
  --name "$ENVIRONMENT" \
  --resource-group "$RESOURCE_GROUP" \
  --location "$LOCATION"

Adja hozzá a következő értékeket a kafka-dev.bicep fájlhoz.

resource appEnvironment 'Microsoft.App/managedEnvironments@2023-04-01-preview' = {
  name: appEnvironmentName
  location: location
  properties: {
    appLogsConfiguration: {
      destination: 'azure-monitor'
    }
  }
}

Az Azure CLI automatikusan létrehoz egy Log Analytics-munkaterületet minden környezethez. Ha Bicep-sablonnal szeretne munkaterületet létrehozni, explicit módon deklarálja a környezetet, és hivatkozik rá a sablonban. Ez a lépés stabilabbá teszi az üzembe helyezést, még akkor is, ha egy kis részletesség árán is.

Adja hozzá a következő értékeket a környezethez.

resource logAnalytics 'Microsoft.OperationalInsights/workspaces@2022-10-01' = {
  name: '${appEnvironmentName}-log-analytics'
  location: location
  properties: {
    sku: {
      name: 'PerGB2018'
    }
  }
}

resource appEnvironment 'Microsoft.App/managedEnvironments@2023-04-01-preview' = {
  name: appEnvironmentName
  location: location
  properties: {
    appLogsConfiguration: {
      destination: 'log-analytics'
      logAnalyticsConfiguration: {
        customerId: logAnalytics.properties.customerId
        sharedKey: logAnalytics.listKeys().primarySharedKey
      }
    }
  }
}

A bicep-modulok által azd használt sablonok.

Hozzon létre egy nevű ./infra/core/hostmappát, majd hozzon létre egy modult ./infra/core/host/container-apps-environment.bicep az alábbi tartalommal.

param name string
param location string = resourceGroup().location
param tags object = {}

resource logAnalytics 'Microsoft.OperationalInsights/workspaces@2022-10-01' = {
  name: '${name}-log-analytics'
  location: location
  tags: tags
  properties: {
    sku: {
      name: 'PerGB2018'
    }
  }
}

resource appEnvironment 'Microsoft.App/managedEnvironments@2023-04-01-preview' = {
  name: name
  location: location
  tags: tags
  properties: {
    appLogsConfiguration: {
      destination: 'log-analytics'
      logAnalyticsConfiguration: {
        customerId: logAnalytics.properties.customerId
        sharedKey: logAnalytics.listKeys().primarySharedKey
      }
    }
  }
}

output appEnvironmentId string = appEnvironment.id

A fájlban ./infra/main.bicep töltse be a modult az alábbi értékekkel.

module appEnvironment './core/host/container-apps-environment.bicep' = {
  name: 'appEnvironment'
  scope: rg
  params: {
    name: appEnvironmentName
    location: location
    tags: tags
  }
}

A sablon üzembe helyezéséhez futtassa a azd up parancsot.

Apache Kafka-szolgáltatás létrehozása

Apache Kafka-szolgáltatás létrehozása.

ENVIRONMENT_ID=$(az containerapp env show \
  --name "$ENVIRONMENT" \
  --resource-group "$RESOURCE_GROUP" \
  --output tsv \
  --query id)

Adja hozzá a következő értékeket a következőhöz kafka-dev.bicep:

resource kafka 'Microsoft.App/containerApps@2023-04-01-preview' = {
  name: kafkaSvcName
  location: location
  properties: {
    environmentId: appEnvironment.id
    configuration: {
      service: {
          type: 'kafka'
      }
    }
  }
}

output kafkaLogs string = 'az containerapp logs show -n ${kafka.name} -g ${resourceGroup().name} --follow --tail 30'

Hozzon létre egy modulfájlt ./infra/core/host/container-app-service.bicep az alábbi tartalommal.

param name string
param location string = resourceGroup().location
param tags object = {}
param environmentId string
param serviceType string


resource service 'Microsoft.App/containerApps@2023-04-01-preview' = {
  name: name
  location: location
  tags: tags
  properties: {
    environmentId: environmentId
    configuration: {
      service: {
          type: serviceType
      }
    }
  }
}

output serviceId string = service.id

Ezután frissítse a ./infra/main.bicep modulfájlt az alábbi deklarációval.

module kafka './core/host/container-app-service.bicep' = {
  name: 'kafka'
  scope: rg
  params: {
    name: kafkaSvcName
    location: location
    tags: tags
    environmentId: appEnvironment.outputs.appEnvironmentId
    serviceType: 'kafka'
  }
}

A sablon üzembe helyezése.

    az containerapp add-on kafka create \
    --name "$KAFKA_SVC" \
    --resource-group "$RESOURCE_GROUP" \
    --environment "$ENVIRONMENT"

az deployment group create -g $RESOURCE_GROUP \
    --query 'properties.outputs.*.value' \
    --template-file kafka-dev.bicep

Tipp.

A kimenet kafkaLogs egy CLI-parancsot ad ki, amely segít a kafka naplóinak megtekintésében az üzembe helyezés befejezése után. A parancs futtatásával megtekintheti az új Kafka szolgáltatás inicializálási naplóit.

`azd up`

Naplókimenet megtekintése a Kafka-példányból

A parancs használatával megtekintheti a logs naplóüzeneteket.

az containerapp logs show \
    --name $KAFKA_SVC \
    --resource-group $RESOURCE_GROUP \
    --follow --tail 30

Az előző Bicep-példa a naplók megtekintésére szolgáló parancs kimenetét tartalmazza.

Példa:

[
  "az containerapp logs show -n kafka01 -g kafka-dev --follow --tail 30"
]

Ha nem rendelkezik a paranccsal, a szolgáltatásnévvel megtekintheti a naplókat a parancssori felület használatával.

az containerapp logs show \
    --name $KAFKA_SVC \
    --resource-group $RESOURCE_GROUP \
    --follow --tail 30

A parancs használatával megtekintheti a logs naplóüzeneteket.

az containerapp logs show \
    --name kafka01 \
    --resource-group $RESOURCE_GROUP \
    --follow --tail 30

Képernyőkép a tárolóalkalmazás kafka szolgáltatásnaplóiról.

Alkalmazás létrehozása a szolgáltatás teszteléséhez

Az alkalmazás létrehozásakor beállíthatja, hogy a Kafka-példányt használja./kafka-topics.sh./kafka-console-producer.sh, és kafka-console-consumer.sh csatlakozzon hozzá.

Hozzon létre egy kafka-cli-app alkalmazást, amely a Kafka szolgáltatáshoz kapcsolódik.

az containerapp create \
    --name "$KAFKA_CLI_APP" \
    --image mcr.microsoft.com/k8se/services/kafka:3.4 \
    --bind "$KAFKA_SVC" \
    --environment "$ENVIRONMENT" \
    --resource-group "$RESOURCE_GROUP" \
    --min-replicas 1 \
    --max-replicas 1 \
    --command "/bin/sleep" "infinity"

Adja hozzá a következőket az értékekhez kafka-dev.bicep.

resource kafkaCli 'Microsoft.App/containerApps@2023-04-01-preview' = {
  name: kafkaCliAppName
  location: location
  properties: {
    environmentId: appEnvironment.id
    template: {
      serviceBinds: [
        {
          serviceId: kafka.id
        }
      ]
      containers: [
        {
          name: 'kafka-cli'
          image: 'mcr.microsoft.com/k8se/services/kafka:3.4'
          command: [ '/bin/sleep', 'infinity' ]
        }
      ]
      scale: {
        minReplicas: 1
        maxReplicas: 1
      }
    }
  }
}

output kafkaCliExec string = 'az containerapp exec -n ${kafkaCli.name} -g ${resourceGroup().name} --command /bin/bash'

Tipp.

A kimenet kafkaCliExec egy parancssori felületi parancsot ad ki, amellyel ellenőrizheti, hogy az alkalmazás megfelelően van-e üzembe helyezve.

Hozzon létre egy modult, ./infra/core/host/container-app.bicep és adja hozzá a következő értékeket.

param name string
param location string = resourceGroup().location
param tags object = {}

param environmentId string
param serviceId string = ''
param containerName string
param containerImage string
param containerCommands array = []
param containerArgs array = []
param minReplicas int
param maxReplicas int
param targetPort int = 0
param externalIngress bool = false

resource app 'Microsoft.App/containerApps@2023-04-01-preview' = {
  name: name
  location: location
  tags: tags
  properties: {
    environmentId: environmentId
    configuration: {
      ingress: targetPort > 0 ? {
        targetPort: targetPort
        external: externalIngress
      } : null
    }
    template: {
      serviceBinds: !empty(serviceId) ? [
        {
          serviceId: serviceId
        }
      ] : null
      containers: [
        {
          name: containerName
          image: containerImage
          command: !empty(containerCommands) ? containerCommands : null
          args: !empty(containerArgs) ? containerArgs : null
        }
      ]
      scale: {
        minReplicas: minReplicas
        maxReplicas: maxReplicas
      }
    }
  }
}

Most használja a modult ./infra/main.bicep a következő értékek hozzáadásával.

module kafkaCli './core/host/container-app.bicep' = {
  name: 'kafkaCli'
  scope: rg
  params: {
    name: kafkaCliAppName
    location: location
    tags: tags
    environmentId: appEnvironment.outputs.appEnvironmentId
    serviceId: kafka.outputs.serviceId
    containerImage: 'mcr.microsoft.com/k8se/services/kafka:3.4'
    containerName: 'kafka-cli'
    maxReplicas: 1
    minReplicas: 1
    containerCommands: [ '/bin/sleep', 'infinity' ]
  }
}

A sablon üzembe helyezése a következővel azd up: .

azd up

Futtassa a CLI-parancsot exec a tesztalkalmazáshoz való csatlakozáshoz.

az containerapp exec \
    --name $KAFKA_CLI_APP \
    --resource-group $RESOURCE_GROUP \
    --command /bin/bash

Az előző Bicep-példa olyan kimenetet tartalmaz, amely bemutatja, hogyan futtathatja az alkalmazást.

Példa:

[
  "az containerapp logs show -n kafka01 -g kafka-dev --follow --tail 30",
  "az containerapp exec -n kafka-cli-app -g kafka-dev --command /bin/bash"
]

Ha nem rendelkezik a paranccsal, az alkalmazás nevével futtathatja az alkalmazást a exec paranccsal.

az containerapp exec \
    --name $KAFKA_CLI_APP \
    --resource-group $RESOURCE_GROUP \
    --command /bin/bash

az containerapp exec \
    --name kafka-cli-app \
    --resource-group $RESOURCE_GROUP \
    --command /bin/bash

Amikor a tesztalkalmazást használja --bind vagy serviceBinds használja, a rendszer beszúrja a kapcsolati adatokat az alkalmazáskörnyezetbe. Miután csatlakozott a teszttárolóhoz, a parancs használatával megvizsgálhatja az env értékeket.

env | grep "^KAFKA_"

KAFKA_SECURITYPROTOCOL=SASL_PLAINTEXT
KAFKA_BOOTSTRAPSERVER=kafka01:9092
KAFKA_HOME=/opt/kafka
KAFKA_PROPERTIES_SASL_JAAS_CONFIG=org.apache.kafka.common.security.plain.PlainLoginModule required username="kafka-user" password="7dw..." user_kafka-user="7dw..." ;
KAFKA_BOOTSTRAP_SERVERS=kafka01:9092
KAFKA_SASLUSERNAME=kafka-user
KAFKA_SASL_USER=kafka-user
KAFKA_VERSION=3.4.0
KAFKA_SECURITY_PROTOCOL=SASL_PLAINTEXT
KAFKA_SASL_PASSWORD=7dw...
KAFKA_SASLPASSWORD=7dw...
KAFKA_SASL_MECHANISM=PLAIN
KAFKA_SASLMECHANISM=PLAIN

Eseménytémakör létrehozásához használható kafka-topics.sh .

Hozzon létre egy kafka.props fájlt.

echo "security.protocol=$KAFKA_SECURITY_PROTOCOL" >> kafka.props && \
echo "sasl.mechanism=$KAFKA_SASL_MECHANISM" >> kafka.props && \
echo "sasl.jaas.config=$KAFKA_PROPERTIES_SASL_JAAS_CONFIG" >> kafka.props

quickstart-events Eseménytémakör létrehozása.

/opt/kafka/bin/kafka-topics.sh \
    --create --topic quickstart-events \
    --bootstrap-server $KAFKA_BOOTSTRAP_SERVERS \
    --command-config kafka.props
# Created topic quickstart-events.

/opt/kafka/bin/kafka-topics.sh \
    --describe --topic quickstart-events \
    --bootstrap-server $KAFKA_BOOTSTRAP_SERVERS \
    --command-config kafka.props
# Topic: quickstart-events	TopicId: lCkTKmvZSgSUCHozhhvz1Q	PartitionCount: 1	ReplicationFactor: 1	Configs: segment.bytes=1073741824
# Topic: quickstart-events	Partition: 0	Leader: 1	Replicas: 1	Isr: 1

Eseményeket kafka-console-producer.sh írhat a témakörbe.

/opt/kafka/bin/kafka-console-producer.sh \
    --topic quickstart-events \
    --bootstrap-server $KAFKA_BOOTSTRAP_SERVERS \
    --producer.config kafka.props

> this is my first event
> this is my second event
> this is my third event
> CTRL-C

Feljegyzés

A ./kafka-console-producer.sh parancssor arra kéri, hogy írjon eseményeket a következővel >: . Írjon néhány eseményt az ábrán látható módon, majd lépjen CTRL-C ki.

A témakör eseményeinek olvasására használható kafka-console-consumer.sh .

/opt/kafka/bin/kafka-console-consumer.sh \
     --topic quickstart-events \
    --bootstrap-server $KAFKA_BOOTSTRAP_SERVERS \
    --from-beginning \
    --consumer.config kafka.props

# this is my first event
# this is my second event
# this is my third event

Képernyőkép a tárolóalkalmazás kafka CLI kimeneti naplóiról.

Fejlesztői szolgáltatás használata meglévő alkalmazással

Ha már rendelkezik Apache Kafkát használó alkalmazással, módosíthatja a kapcsolati adatok betöltésének módját.

Először hozza létre a következő környezeti változókat.

KAFKA_HOME=/opt/kafka
KAFKA_PROPERTIES_SASL_JAAS_CONFIG=org.apache.kafka.common.security.plain.PlainLoginModule required username="kafka-user" password="7dw..." user_kafka-user="7dw..." ;
KAFKA_BOOTSTRAP_SERVERS=kafka01:9092
KAFKA_SASL_USER=kafka-user
KAFKA_VERSION=3.4.0
KAFKA_SECURITY_PROTOCOL=SASL_PLAINTEXT
KAFKA_SASL_PASSWORD=7dw...
KAFKA_SASL_MECHANISM=PLAIN

A parancssori felület (vagy a Bicep) használatával frissítheti az alkalmazást, hogy hozzáadja --bind $KAFKA_SVC a dev szolgáltatás használatához.

Kötés a fejlesztői szolgáltatáshoz

A Kafka-ui üzembe helyezése a Kafka-példány megtekintéséhez és kezeléséhez.

Lásd: Bicep vagy azd példa.

resource kafkaUi 'Microsoft.App/containerApps@2023-04-01-preview' = {
  name: kafkaUiAppName
  location: location
  properties: {
    environmentId: appEnvironment.id
    configuration: {
      ingress: {
        external: true
        targetPort: 8080
      }
    }
    template: {
      serviceBinds: [
        {
          serviceId: kafka.id
          name: 'kafka'
        }
      ]
      containers: [
        {
          name: 'kafka-ui'
          image: 'docker.io/provectuslabs/kafka-ui:latest'
          command: [
            '/bin/sh'
          ]
          args: [
            '-c'
            '''export KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS="$KAFKA_BOOTSTRAP_SERVERS" && \
            export KAFKA_CLUSTERS_0_PROPERTIES_SASL_JAAS_CONFIG="$KAFKA_PROPERTIES_SASL_JAAS_CONFIG" && \
            export KAFKA_CLUSTERS_0_PROPERTIES_SASL_MECHANISM="$KAFKA_SASL_MECHANISM" && \
            export KAFKA_CLUSTERS_0_PROPERTIES_SECURITY_PROTOCOL="$KAFKA_SECURITY_PROTOCOL" && \
            java $JAVA_OPTS -jar kafka-ui-api.jar'''
          ]
          resources: {
            cpu: json('1.0')
            memory: '2.0Gi'
          }
        }
      ]
    }
  }
}

output kafkaUiUrl string = 'https://${kafkaUi.properties.configuration.ingress.fqdn}'

A Bicep parancs egy URL-címet ad vissza. Másolja ezt az URL-címet a böngészőbe az üzembe helyezett webhely felkereséséhez.

Frissítsen ./infra/main.bicep a következő értékekkel.

module kafkaUi './core/host/container-app.bicep' = {
  name: 'kafka-ui'
  scope: rg
  params: {
    name: kafkaUiAppName
    location: location
    tags: tags
    environmentId: appEnvironment.outputs.appEnvironmentId
    serviceId: kafka.outputs.serviceId
    containerImage: 'docker.io/provectuslabs/kafka-ui:latest'
    containerName: 'kafka-ui'
    maxReplicas: 1
    minReplicas: 1
    containerCommands: [ '/bin/sh' ]
    containerArgs: [ 
      '-c'
      '''export KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS="$KAFKA_BOOTSTRAP_SERVERS" && \
      export KAFKA_CLUSTERS_0_PROPERTIES_SASL_JAAS_CONFIG="$KAFKA_PROPERTIES_SASL_JAAS_CONFIG" && \
      export KAFKA_CLUSTERS_0_PROPERTIES_SASL_MECHANISM="$KAFKA_SASL_MECHANISM" && \
      export KAFKA_CLUSTERS_0_PROPERTIES_SECURITY_PROTOCOL="$KAFKA_SECURITY_PROTOCOL" && \
      java $JAVA_OPTS -jar kafka-ui-api.jar'''
    ]
    targetPort: 8080
    externalIngress: true
  }
}

A sablon üzembe helyezése a következővel azd up: .

azd up

Képernyőkép a Kafka szolgáltatáshoz csatlakozó pgweb Container Appról.

Az összes erőforrás üzembe helyezése

Ha az összes erőforrást egyszerre szeretné üzembe helyezni, használja az alábbi példákat.

Bicep

Az alábbi Bicep-sablon az oktatóanyag összes erőforrását tartalmazza.

Ezzel a tartalommal hozhat létre kafka-dev.bicep fájlt.

targetScope = 'resourceGroup'
param location string = resourceGroup().location
param appEnvironmentName string = 'aca-env'
param kafkaSvcName string = 'kafka01'
param kafkaCliAppName string = 'kafka-cli-app'
param kafkaUiAppName string = 'kafka-ui'

resource logAnalytics 'Microsoft.OperationalInsights/workspaces@2022-10-01' = {
  name: '${appEnvironmentName}-log-analytics'
  location: location
  properties: {
    sku: {
      name: 'PerGB2018'
    }
  }
}

resource appEnvironment 'Microsoft.App/managedEnvironments@2023-04-01-preview' = {
  name: appEnvironmentName
  location: location
  properties: {
    appLogsConfiguration: {
      destination: 'log-analytics'
      logAnalyticsConfiguration: {
        customerId: logAnalytics.properties.customerId
        sharedKey: logAnalytics.listKeys().primarySharedKey
      }
    }
  }
}

resource kafka 'Microsoft.App/containerApps@2023-04-01-preview' = {
  name: kafkaSvcName
  location: location
  properties: {
    environmentId: appEnvironment.id
    configuration: {
      service: {
          type: 'kafka'
      }
    }
  }
}

resource kafkaCli 'Microsoft.App/containerApps@2023-04-01-preview' = {
  name: kafkaCliAppName
  location: location
  properties: {
    environmentId: appEnvironment.id
    template: {
      serviceBinds: [
        {
          serviceId: kafka.id
        }
      ]
      containers: [
        {
          name: 'kafka-cli'
          image: 'mcr.microsoft.com/k8se/services/kafka:3.4'
          command: [ '/bin/sleep', 'infinity' ]
        }
      ]
      scale: {
        minReplicas: 1
        maxReplicas: 1
      }
    }
  }
}

resource kafkaUi 'Microsoft.App/containerApps@2023-04-01-preview' = {
  name: kafkaUiAppName
  location: location
  properties: {
    environmentId: appEnvironment.id
    configuration: {
      ingress: {
        external: true
        targetPort: 8080
      }
    }
    template: {
      serviceBinds: [
        {
          serviceId: kafka.id
          name: 'kafka'
        }
      ]
      containers: [
        {
          name: 'kafka-ui'
          image: 'docker.io/provectuslabs/kafka-ui:latest'
          command: [
            '/bin/sh'
          ]
          args: [
            '-c'
            '''export KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS="$KAFKA_BOOTSTRAP_SERVERS" && \
            export KAFKA_CLUSTERS_0_PROPERTIES_SASL_JAAS_CONFIG="$KAFKA_PROPERTIES_SASL_JAAS_CONFIG" && \
            export KAFKA_CLUSTERS_0_PROPERTIES_SASL_MECHANISM="$KAFKA_SASL_MECHANISM" && \
            export KAFKA_CLUSTERS_0_PROPERTIES_SECURITY_PROTOCOL="$KAFKA_SECURITY_PROTOCOL" && \
            java $JAVA_OPTS -jar kafka-ui-api.jar'''
          ]
          resources: {
            cpu: json('1.0')
            memory: '2.0Gi'
          }
        }
      ]
    }
  }
}

output kafkaUiUrl string = 'https://${kafkaUi.properties.configuration.ingress.fqdn}'

output kafkaCliExec string = 'az containerapp exec -n ${kafkaCli.name} -g ${resourceGroup().name} --command /bin/bash'

output kafkaLogs string = 'az containerapp logs show -n ${kafka.name} -g ${resourceGroup().name} --follow --tail 30'

A sablon üzembe helyezéséhez használja az Azure CLI-t.

RESOURCE_GROUP="kafka-dev"
LOCATION="northcentralus"

az group create \
    --name "$RESOURCE_GROUP" \
    --location "$LOCATION"

az deployment group create -g $RESOURCE_GROUP \
    --query 'properties.outputs.*.value' \
    --template-file kafka-dev.bicep

Azure Developer CLI

Egy végleges sablon érhető el a GitHubon.

A sablon üzembe helyezésére használható azd up .

git clone https://github.com/Azure-Samples/aca-dev-service-kafka-azd
cd aca-dev-service-kafka-azd
azd up

Az erőforrások eltávolítása

Ha végzett, futtassa a következő parancsot a Container Apps-erőforrásokat tartalmazó erőforráscsoport törléséhez.

Figyelemfelhívás

Az alábbi parancs törli a megadott erőforráscsoportot és a benne lévő összes erőforrást. Ha az oktatóanyag hatókörén kívül eső erőforrások a megadott erőforráscsoportban találhatók, akkor azok is törlődnek.

az group delete \
    --resource-group $RESOURCE_GROUP

Megosztás a következőn keresztül: