Samouczek: tworzenie i używanie usługi Apache Kafka do programowania

Usługa Azure Container Apps umożliwia łączenie się z usługami deweloperskimi i produkcyjnymi w celu zapewnienia szerokiej gamy funkcji aplikacji.

Z tego samouczka dowiesz się, jak tworzyć i używać programowania usługi Apache Kafka.

Polecenia interfejsu wiersza polecenia platformy Azure i fragmenty szablonów Bicep są opisywane w tym samouczku. Jeśli używasz Bicep, możesz dodać wszystkie fragmenty do pojedynczego pliku Bicep i wdrożyć cały szablon jednocześnie.

• Tworzenie środowiska usługi Container Apps w celu wdrożenia usługi i aplikacji kontenera
• Tworzenie usługi Apache Kafka
• Konfigurowanie aplikacji wiersza polecenia do korzystania z usługi dev Apache Kafka
• Wdrażanie aplikacji kafka-ui w celu wyświetlania danych aplikacji
• Kompilowanie końcowego szablonu bicep w celu wdrożenia wszystkich zasobów przy użyciu spójnego i przewidywalnego wdrożenia szablonu
• azd Używanie szablonu dla jednego polecenia wdrożenia wszystkich zasobów

Wymagania wstępne

• Zainstaluj interfejs wiersza polecenia platformy Azure.
• Opcjonalnie: interfejs wiersza polecenia dla deweloperów platformy Azure, aby wykonać instrukcje dotyczące usługi AZD.

Uwaga

W przypadku wdrożenia jednego polecenia przejdź do ostatniego azdkroku szablonu.

Ustawienia

1. Zdefiniuj zmienne dla typowych wartości.

   Bash

   RESOURCE_GROUP="kafka-dev"
   LOCATION="northcentralus"
   ENVIRONMENT="aca-env"
   KAFKA_SVC="kafka01"
   KAFKA_CLI_APP="kafka-cli-app"
   KAFKA_UI_APP="kafka-ui-app"
   

   Bicep

   Poniższe zmienne umożliwiają wdrażanie szablonu Bicep przy użyciu interfejsu wiersza polecenia.

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

   W przypadku aplikacji Bicep zacznij od utworzenia pliku o nazwie kafka-dev.bicep, a następnie dodaj parametry z następującymi wartościami domyślnymi.

   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'
   

   Podczas wdrażania szablonu bicep na dowolnym etapie możesz użyć az deployment group create polecenia .

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

   Azd

   Zdefiniuj zmienne początkowe.

   AZURE_ENV_NAME="azd-kafka-dev"
   LOCATION="northcentralus"
   

   Użyj wartości, aby zainicjować minimalny azd szablon.

   azd init \
       --environment "$AZURE_ENV_NAME" \
       --location "$LOCATION" \
       --no-prompt
   

   Uwaga

   AZURE_ENV_NAME różni się od nazwy środowiska aplikacji kontenera. W tym kontekście AZURE_ENV_NAME element in azd dotyczy wszystkich zasobów w szablonie. Te zasoby obejmują zasoby, które nie są skojarzone z usługą Container Apps. Możesz utworzyć inną nazwę dla środowiska Container Apps.

   Następnie utwórz infra/main.bicep i zdefiniuj parametry do późniejszego użycia.

   param appEnvironmentName string = 'aca-env'
   param kafkaSvcName string = 'kafka01'
   param kafkaCliAppName string = 'kafka-cli-app'
   param kafkaUiAppName string = 'kafka-ui'
   

2. Loguje się do platformy Azure.

   az login
   

3. Uaktualnij interfejs wiersza polecenia do najnowszej wersji.

   az upgrade
   

4. Uaktualnij Bicep do najnowszej wersji.

   az bicep upgrade
   

5. Dodaj rozszerzenie.containerapp

   az extension add --name containerapp --upgrade
   

6. Zarejestruj wymagane przestrzenie nazw.

   az provider register --namespace Microsoft.App
   

   az provider register --namespace Microsoft.OperationalInsights
   

Tworzenie środowiska usługi Container Apps

1. Utwórz grupę zasobów.

   Bash

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

   Bicep

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

   Azd

   Do zarządzania grupami zasobów w programie azdnie jest wymagana żadna specjalna konfiguracja. Polecenie azd pobiera grupę AZURE_ENV_NAME/--environment zasobów z wartości .

   Możesz przetestować minimalny szablon za up pomocą polecenia .

   azd up
   

   Uruchomienie tego polecenia powoduje utworzenie pustej grupy zasobów.

2. Tworzenie środowiska usługi Container Apps.

   Bash

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

   Bicep

   Dodaj następujące wartości do kafka-dev.bicep pliku.

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

   Interfejs wiersza polecenia platformy Azure automatycznie tworzy obszar roboczy usługi Log Analytics dla każdego środowiska. Aby wygenerować obszar roboczy przy użyciu szablonu Bicep, jawnie zadeklarujesz środowisko i połączysz je z nim w szablonie. Ten krok sprawia, że wdrożenie jest bardziej stabilne, nawet jeśli koszt jest nieco pełny.

   Dodaj następujące wartości do środowiska.

   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
         }
       }
     }
   }
   

   Azd

   Szablony używane przez azd moduły bicep.

   Utwórz folder o nazwie ./infra/core/host, a następnie utwórz ./infra/core/host/container-apps-environment.bicep moduł z następującą zawartością.

   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
   

   W pliku załaduj ./infra/main.bicep moduł przy użyciu następujących wartości.

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

   Uruchom polecenie azd up, aby wdrożyć szablon.

Tworzenie usługi Apache Kafka

1. Tworzenie usługi Platformy Apache Kafka.

   Bash

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

   Bicep

   Dodaj następujące wartości do 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'
   

   Azd

   Utwórz plik modułu ./infra/core/host/container-app-service.bicep z następującą zawartością.

   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
   

   Następnie zaktualizuj plik modułu ./infra/main.bicep za pomocą następującej deklaracji.

   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'
     }
   }
   

2. Wdrażanie szablonu.

   Bash

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

   Bicep

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

   Napiwek

   Dane wyjściowe kafkaLogs wyświetlają polecenie interfejsu wiersza polecenia, aby ułatwić wyświetlenie dzienników platformy kafka po zakończeniu wdrażania. Możesz uruchomić polecenie , aby wyświetlić dzienniki inicjowania nowej usługi Kafka.

   Azd

   `azd up`
   

3. Wyświetlanie danych wyjściowych dziennika z wystąpienia platformy Kafka

   Bash

   Użyj polecenia , logs aby wyświetlić komunikaty dziennika.

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

   Bicep

   Poprzedni przykład Bicep zawiera dane wyjściowe polecenia w celu wyświetlenia dzienników.

   Na przykład:

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

   Jeśli nie masz polecenia, możesz użyć nazwy usługi, aby wyświetlić dzienniki przy użyciu interfejsu wiersza polecenia.

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

   Azd

   Użyj polecenia , logs aby wyświetlić komunikaty dziennika.

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

   

Tworzenie aplikacji do testowania usługi

Podczas tworzenia aplikacji skonfigurujesz ją tak, aby korzystała z ./kafka-topics.shprogramu , ./kafka-console-producer.shi kafka-console-consumer.sh w celu nawiązania połączenia z wystąpieniem platformy Kafka.

1. Utwórz aplikację powiązaną kafka-cli-app z usługą Kafka.

   Bash

   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"
   

   Bicep

   Dodaj następujące wartości do wartości 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'
   

   Napiwek

   Dane wyjściowe kafkaCliExec wyświetlają polecenie interfejsu wiersza polecenia, które można uruchomić, aby sprawdzić, czy aplikacja została wdrożona poprawnie.

   Azd

   Utwórz moduł w obszarze ./infra/core/host/container-app.bicep i dodaj następujące wartości.

   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
         }
       }
     }
   }
   

   Teraz użyj modułu w programie ./infra/main.bicep , dodając następujące wartości.

   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' ]
     }
   }
   

   Wdróż szablon za pomocą azd uppolecenia .

   azd up
   

2. Uruchom polecenie interfejsu wiersza polecenia exec , aby nawiązać połączenie z aplikacją testowej.

   Bash

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

   Bicep

   Poprzedni przykład Bicep zawiera dane wyjściowe pokazujące, jak uruchomić aplikację.

   Na przykład:

   [
     "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"
   ]
   

   Jeśli nie masz polecenia, możesz użyć nazwy aplikacji, aby uruchomić aplikację przy użyciu exec polecenia .

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

   Azd

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

   W przypadku korzystania z --bind aplikacji testowej lub serviceBinds w aplikacji testowej informacje o połączeniu są wstrzykiwane do środowiska aplikacji. Po nawiązaniu połączenia z kontenerem testowym możesz sprawdzić wartości przy użyciu env polecenia .

   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
   

3. Użyj kafka-topics.sh polecenia , aby utworzyć temat zdarzenia.

   Utwórz plik kafka.props.

   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 Utwórz temat zdarzenia.

   /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
   

4. Służy kafka-console-producer.sh do zapisywania zdarzeń w temacie.

   /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
   

   Uwaga

   Polecenie ./kafka-console-producer.sh wyświetla monit o zapisanie zdarzeń za pomocą polecenia >. Napisz kilka zdarzeń, jak pokazano, a następnie naciśnij polecenie CTRL-C , aby zakończyć.

5. Służy kafka-console-consumer.sh do odczytywania zdarzeń z tematu.

   /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
   

Używanie usługi dewelopera z istniejącą aplikacją

Jeśli masz już aplikację korzystającą z platformy Apache Kafka, możesz zmienić sposób ładowania informacji o połączeniu.

Najpierw utwórz następujące zmienne środowiskowe.

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

Za pomocą interfejsu wiersza polecenia (lub Bicep) możesz zaktualizować aplikację, aby dodać --bind $KAFKA_SVC aplikację do korzystania z usługi dewelopera.

Wiązanie z usługą dewelopera

Wdróż kafka-ui , aby wyświetlić wystąpienie platformy Kafka i zarządzać nim.

Bash

Zobacz Bicep lub azd przykład.

Bicep

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}'

Polecenie Bicep zwraca adres URL. Skopiuj ten adres URL do przeglądarki, aby przejść do wdrożonej witryny.

Azd

Zaktualizuj ./infra/main.bicep przy użyciu następujących wartości.

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
  }
}

Wdróż szablon za pomocą azd uppolecenia .

azd up

Wdrażanie wszystkich zasobów

Skorzystaj z poniższych przykładów, aby wdrożyć wszystkie zasoby jednocześnie.

Bicep

Poniższy szablon Bicep zawiera wszystkie zasoby w tym samouczku.

Możesz utworzyć kafka-dev.bicep plik z tą zawartością.

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'

Użyj interfejsu wiersza polecenia platformy Azure, aby wdrożyć go w szablonie.

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

Ostateczny szablon jest dostępny w witrynie GitHub.

Użyj polecenia azd up , aby wdrożyć szablon.

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

Czyszczenie zasobów

Po zakończeniu uruchom następujące polecenie, aby usunąć grupę zasobów zawierającą zasoby usługi Container Apps.

Uwaga

Następujące polecenie usuwa określoną grupę zasobów i wszystkie zawarte w niej zasoby. Jeśli zasoby spoza zakresu tego samouczka istnieją w określonej grupie zasobów, zostaną również usunięte.

az group delete \
    --resource-group $RESOURCE_GROUP