{"id":46721,"date":"2023-12-05T01:55:31","date_gmt":"2023-08-19T20:29:09","guid":{"rendered":"https:\/\/www.silicloud.com\/zh\/blog\/46721-2\/"},"modified":"2024-05-04T12:10:35","modified_gmt":"2024-05-04T04:10:35","slug":"46721-2","status":"publish","type":"post","link":"https:\/\/www.silicloud.com\/zh\/blog\/46721-2\/","title":{"rendered":""},"content":{"rendered":"

\u306f\u3058\u3081\u306b<\/h2>\n

Azure\u4e0a\u3067PaaS\u3068\u3057\u3066Apache Kafka\u3092\u52d5\u304b\u3059\u5834\u5408\u3001\u30aa\u30d7\u30b7\u30e7\u30f3\u3068\u3057\u3066\u8003\u3048\u3089\u308c\u308b\u306e\u306fEvent Hub\u306eKafka\u4e92\u63dbAPI\u3092\u4f7f\u7528\u3059\u308b\u304b\u3001HDInsight\u3067Kafka Cluster\u3092\u52d5\u304b\u3059\u65b9\u6cd5\u304c\u3042\u308b\u3002Event Hub\u306e\u307b\u3046\u304c\u30af\u30e9\u30a6\u30c9\u30de\u30cd\u30fc\u30b8\u306e\u5ea6\u5408\u3044\u304c\u9ad8\u304f\u3001HDInsight\u306e\u307b\u3046\u306f\u30e6\u30fc\u30b6\u30fc\u30de\u30cd\u30fc\u30b8\u306e\u5ea6\u5408\u3044\u304c\u9ad8\u3044\u3002\u3044\u305a\u308c\u306b\u3057\u3066\u3082Kafka\u3092\u5229\u7528\u3059\u308b\u306b\u306fKafka\u306b\u30c7\u30fc\u30bf\u3092\u9001\u4fe1\u3059\u308bProducer\u3084Kafka\u304b\u3089\u30c7\u30fc\u30bf\u3092\u53d6\u5f97\u3059\u308bConsumer\u304c\u5fc5\u8981\u306b\u306a\u308b\u3002\u3044\u308d\u3044\u308d\u306a\u65b9\u6cd5\u304c\u3042\u308b\u3068\u601d\u3046\u304c\u3001\u4eca\u56de\u306fAzure Functions\u3092\u4f7f\u3063\u3066\u30b9\u30b1\u30fc\u30e9\u30d6\u30eb\u306akafka Producer\u3092\u69cb\u7bc9\u3059\u308b\u3053\u3068\u3092\u8a66\u3057\u305f\u306e\u3067\u305d\u308c\u3092\u30e1\u30e2\u3057\u3066\u304a\u304f\u3002<\/p>\n

\u69cb\u6210<\/h2>\n
\"image.png\"<\/div>\n

\u74b0\u5883\u8a2d\u5b9a<\/h2>\n

VNET\u3068Subnet\u4f5c\u6210<\/h3>\n

\u4e0a\u306e\u30c0\u30a4\u30a2\u30b0\u30e9\u30e0\u306b\u57fa\u3065\u3044\u3066\u3001\u4eee\u60f3\u30cd\u30c3\u30c8\u30ef\u30fc\u30af\u3068\u30b5\u30d6\u30cd\u30c3\u30c8\u3092\u4f5c\u6210\u3002\u540d\u524d\u3084IP\u30a2\u30c9\u30ec\u30b9\u306f\u3053\u3053\u3067\u306f\u9069\u5f53\u306b\u5165\u308c\u3066\u3044\u308b\u3053\u3068\u306b\u6ce8\u610f\u3002<\/p>\n

export <\/span>MyResourceGroup<\/span>=<\/span>\"myRG\"<\/span>\r\nexport <\/span>vnetName<\/span>=<\/span>\"myVnet\"<\/span>\r\nexport <\/span>VnetPrefix<\/span>=<\/span>\"10.10.0.0\/16\"<\/span>\r\nexport <\/span>FunctionsSubnet<\/span>=<\/span>\"Functions-Subnet\"<\/span>\r\nexport <\/span>FunctionsSubnetPrefix<\/span>=<\/span>\"10.10.10.0\/24\"<\/span>\r\nexport <\/span>KafkaSubnet<\/span>=<\/span>\"Kafka-Subnet\"<\/span>\r\nexport <\/span>KafkaSubnetPrefix<\/span>=<\/span>\"10.10.20.0\/24\"<\/span>\r\nexport <\/span>location<\/span>=<\/span>\"japaneast\"<\/span>\r\n\r\n# Create Reource Group<\/span>\r\naz group create --name<\/span> $MyResourceGroup<\/span> --location<\/span> $location<\/span>\r\n\r\n# Create VNET with a Subnet for Functions. More than \/24 address range is required for VNet Integration<\/span>\r\naz network vnet create -g<\/span> $MyResourceGroup<\/span> -n<\/span> $vnetName<\/span> --address-prefix<\/span> $VnetPrefix<\/span> \\<\/span>\r\n    --subnet-name<\/span> $FunctionsSubnet<\/span> --subnet-prefix<\/span> $FunctionsSubnetPrefix<\/span>\r\n\r\n# Create Subnet for Kafka on HDInsight<\/span>\r\naz network vnet subnet create -g<\/span> $MyResourceGroup<\/span> --vnet-name<\/span> $vnetName<\/span> -n<\/span> $KafkaSubnet<\/span> \\<\/span>\r\n    --address-prefixes<\/span> $KafkaSubnetPrefix<\/span>\r\n<\/code><\/pre>\n
Functions\u306e\u4f5c\u6210<\/h3>\n
VNET Integration\u3092\u4f7f\u7528\u3059\u308b\u5834\u5408\u306f\u3001Standard\u3001Premium\u307e\u305f\u306f\u306e\u4fa1\u683c\u30d7\u30e9\u30f3\u304c\u5fc5\u8981\u3068\u306a\u308b\u3002\u4eca\u56de\u306fPremium (EP1)\u3092\u4f7f\u7528\u3002<\/p>\n
# Function app and storage account names must be unique.<\/span>\r\nexport <\/span>storageName<\/span>=<\/span>functionstor$RANDOM<\/span>\r\nexport <\/span>functionAppName<\/span>=<\/span>functionkafkaproducer\r\nexport <\/span>premiumplanName<\/span>=<\/span>myappspremplan\r\n\r\n# Create an azure storage account<\/span>\r\naz storage account create \\<\/span>\r\n  --name<\/span> $storageName<\/span> \\<\/span>\r\n  --location<\/span> $location<\/span> \\<\/span>\r\n  --resource-group<\/span> $MyResourceGroup<\/span> \\<\/span>\r\n  --sku<\/span> Standard_LRS\r\n\r\n# Create a Premium plan<\/span>\r\naz functionapp plan create \\<\/span>\r\n  --name<\/span> $premiumplanName<\/span> \\<\/span>\r\n  --resource-group<\/span> $MyResourceGroup<\/span> \\<\/span>\r\n  --location<\/span> $location<\/span> \\<\/span>\r\n  --sku<\/span> EP1\r\n\r\n# Create a Function App<\/span>\r\naz functionapp create \\<\/span>\r\n  --name<\/span> $functionAppName<\/span> \\<\/span>\r\n  --storage-account<\/span> $storageName<\/span> \\<\/span>\r\n  --plan<\/span> $premiumplanName<\/span> \\<\/span>\r\n  --resource-group<\/span> $MyResourceGroup<\/span> \\<\/span>\r\n  --runtime<\/span> java \\<\/span>\r\n  --functions-version<\/span> 3\r\n<\/code><\/pre>\n
HDInsight Kafka cluster\u306e\u4f5c\u6210<\/h3>\n
\u4e8b\u524d\u306b\u4f5c\u6210\u3057\u305f\u30b5\u30d6\u30cd\u30c3\u30c8\u5185\u306b\u63a5\u7d9a\u3059\u308b\u3053\u3068\u304c\u3067\u304d\u308b\u3088\u3046\u306b\u3001 –subnet \u30aa\u30d7\u30b7\u30e7\u30f3\u3092\u6307\u5b9a\u3059\u308b\u3002\u3053\u3053\u3067\u30b5\u30d6\u30cd\u30c3\u30c8\u540d\u3092\u6307\u5b9a\u3059\u308b\u5834\u5408\u306f\u3001\u4eee\u60f3\u30cd\u30c3\u30c8\u30ef\u30fc\u30af\u3068HDInsight\u30af\u30e9\u30b9\u30bf\u30fc\u306e\u30ea\u30bd\u30fc\u30b9\u30b0\u30eb\u30fc\u30d7\u304c\u540c\u3058\u5834\u5408\u306b\u306f\u52d5\u4f5c\u3059\u308b\u304c\u3001\u30ea\u30bd\u30fc\u30b9\u30b0\u30eb\u30fc\u30d7\u304c\u7570\u306a\u308b\u5834\u5408\u306f\u30b5\u30d6\u30cd\u30c3\u30c8\u540d\u6307\u5b9a\u3067\u306f\u30c7\u30d7\u30ed\u30a4\u3067\u304d\u306a\u3044\u3002\u30ea\u30bd\u30fc\u30b9\u30b0\u30eb\u30fc\u30d7\u304c\u7570\u306a\u308b\u5834\u5408\u306f\u30b5\u30d6\u30cd\u30c3\u30c8ID\u3092\u6307\u5b9a\u3059\u308b\u5fc5\u8981\u304c\u3042\u308b\u3002\u4eca\u56de\u306f\u540c\u3058\u30ea\u30bd\u30fc\u30b9\u30b0\u30eb\u30fc\u30d7\u5185\u306b\u4f5c\u6210\u3059\u308b\u305f\u3081\u3001\u30b5\u30d6\u30cd\u30c3\u30c8\u540d\u306e\u6307\u5b9a\u3067OK\u3002<\/p>\n
export <\/span>clusterName<\/span>=<\/span>\"mykafkacluster\"<\/span>\r\nexport <\/span>storageAccount<\/span>=<\/span>\"myhdikafkastor1\"<\/span>\r\nexport <\/span>httpPassword<\/span>=<\/span>'<Your Cluster Admin Password>'<\/span>\r\nexport <\/span>sshPassword<\/span>=<\/span>'<Your SSH Password>'<\/span>\r\n\r\nexport <\/span>storageContainer<\/span>=<\/span>$(<\/span>echo<\/span> $clusterName<\/span> | tr<\/span> \"[:upper:]\"<\/span> \"[:lower:]\"<\/span>)<\/span>\r\nexport <\/span>workernodeCount<\/span>=<\/span>3\r\nexport <\/span>clusterType<\/span>=<\/span>kafka\r\nexport <\/span>clusterVersion<\/span>=<\/span>4.0\r\nexport <\/span>componentVersion<\/span>=<\/span>kafka<\/span>=<\/span>2.1\r\nexport <\/span>subnet<\/span>=<\/span>\"H\"<\/span>\r\n\r\n# Create storage account<\/span>\r\naz storage account create \\<\/span>\r\n    --name<\/span> $storageAccount<\/span> \\<\/span>\r\n    --resource-group<\/span> $resourceGroupName<\/span> \\<\/span>\r\n    --https-only<\/span> true<\/span> \\<\/span>\r\n    --kind<\/span> StorageV2 \\<\/span>\r\n    --location<\/span> $location<\/span> \\<\/span>\r\n    --sku<\/span> Standard_LRS\r\n\r\n# Export primary key of Storage Account<\/span>\r\nexport <\/span>storageAccountKey<\/span>=<\/span>$(<\/span>az storage account keys list \\<\/span>\r\n    --account-name<\/span> $storageAccount<\/span> \\<\/span>\r\n    --resource-group<\/span> $resourceGroupName<\/span> \\<\/span>\r\n    --query<\/span> [<\/span>0].value -o<\/span> tsv)<\/span>\r\n\r\n# Create blob container<\/span>\r\naz storage container create \\<\/span>\r\n    --name<\/span> $storageContainer<\/span> \\<\/span>\r\n    --account-key<\/span> $storageAccountKey<\/span> \\<\/span>\r\n    --account-name<\/span> $storageAccount<\/span>\r\n\r\n# Create HDInsight Kafka clusterName<\/span>\r\naz hdinsight create \\<\/span>\r\n    --name<\/span> $clusterName<\/span> \\<\/span>\r\n    --resource-group<\/span> $resourceGroupName<\/span> \\<\/span>\r\n    --type<\/span> $clusterType<\/span> \\<\/span>\r\n    --component-version<\/span> $componentVersion<\/span> \\<\/span>\r\n    --http-password<\/span> $httpPassword<\/span> \\<\/span>\r\n    --http-user<\/span> admin \\<\/span>\r\n    --location<\/span> $location<\/span> \\<\/span>\r\n    --ssh-password<\/span> $sshPassword<\/span> \\<\/span>\r\n    --ssh-user<\/span> sshuser \\<\/span>\r\n    --storage-account<\/span> $storageAccount<\/span> \\<\/span>\r\n    --storage-account-key<\/span> $storageAccountKey<\/span> \\<\/span>\r\n    --storage-container<\/span> $storageContainer<\/span> \\<\/span>\r\n    --version<\/span> $clusterVersion<\/span> \\<\/span>\r\n    --workernode-count<\/span> $workernodeCount<\/span> \\<\/span>\r\n    --workernode-data-disks-per-node<\/span> 2 \\<\/span>\r\n    --vnet<\/span> $vnetName<\/span> \\<\/span>\r\n    --subnet<\/span> $KafkaSubnet<\/span>\r\n<\/code><\/pre>\n
Functions\u3067VNET Integration\u8a2d\u5b9a<\/h3>\n
\"image.png\"<\/div>\n
\"image.png\"<\/div>\n
VNet Integration\u3092\u8a2d\u5b9a\u3057\u305f\u3060\u3051\u3067\u306f\u3001Functions\u306f\u4eee\u60f3\u30cd\u30c3\u30c8\u30ef\u30fc\u30af\u5185\u306e\u5185\u90e8\u306e\u540d\u524d\u89e3\u6c7a\u3092\u3059\u308b\u3053\u3068\u304c\u3067\u304d\u306a\u3044\u305f\u3081\u3001\u305d\u306e\u307e\u307e\u3067\u306fKafka Broker\u306b\u63a5\u7d9a\u3059\u308b\u3053\u3068\u304c\u3067\u304d\u306a\u3044\u3002\u305d\u306e\u305f\u3081\u3001\u5185\u90e8DNS\u3092\u53c2\u7167\u3059\u308b\u3053\u3068\u304c\u3067\u304d\u308b\u3088\u3046\u306b\u4ee5\u4e0b\u306e\u8a2d\u5b9a\u3092\u8ffd\u52a0\u3059\u308b\u5fc5\u8981\u304c\u3042\u308b\u3002<\/p>\n
\n
NameValue
\nWEBSITE_DNS_SERVER168.63.129.16\u5185\u90e8DNS\u306e\u30a2\u30c9\u30ec\u30b9\u3092\u6307\u5b9aWEBSITE_VNET_ROUTE_ALL1RFC1918\u4ee5\u5916\u306e\u5b9b\u5148\u3082VNET\u7d4c\u7531\u306b\u3059\u308b<\/div>\n<\/div>\n
\"image.png\"<\/div>\n
Kafka Producer\u306e\u4f5c\u6210<\/h2>\n
\u74b0\u5883\u306e\u6e96\u5099\u304c\u3067\u304d\u305f\u3089\u3001Kafka Producer\u3092\u4f5c\u6210\u306b\u3068\u308a\u304b\u304b\u308b\u3002Kafka client\u3092\u4f7f\u7528\u3059\u308b\u305f\u3081\u306b\u3001 maven\u306e\u4f9d\u5b58\u95a2\u4fc2\u306b\u4ee5\u4e0b\u3092\u8ffd\u52a0\u3059\u308b\u3002\u4eca\u56de\u306f\u30c7\u30d7\u30ed\u30a4\u3057\u305fHDInsight\u306eKafka\u306e\u30d0\u30fc\u30b8\u30e7\u30f3\u306b\u5408\u308f\u305b\u30662.1.0\u3092\u4f7f\u7528<\/p>\n
pom.xml\u306e properties \u306b\u4ee5\u4e0b\u3092\u8ffd\u52a0<\/p>\n
<properties><\/span>\r\n    <kafka.version><\/span>2.1.0<\/kafka.version><\/span>\r\n<\/properties><\/span>\r\n<\/code><\/pre>\n
pom.xml\u306e dependencies \u306b\u4ee5\u4e0b\u3092\u8ffd\u52a0<\/p>\n
<dependency><\/span>\r\n    <groupId><\/span>org.apache.kafka<\/groupId><\/span>\r\n    <artifactId><\/span>kafka-clients<\/artifactId><\/span>\r\n    <version><\/span>${kafka.version}<\/version><\/span>\r\n<\/dependency><\/span>\r\n<\/code><\/pre>\n
Produer\u306e\u51e6\u7406\u306e\u90e8\u5206\u3092\u4f5c\u6210\u3002\u4ee5\u4e0b\u306e\u30b3\u30fc\u30c9\u306f1\u30e1\u30c3\u30bb\u30fc\u30b8\u304cPOST\u3055\u308c\u305f\u3089\u90fd\u5ea6Kafka\u306b\u9001\u4fe1\u3057\u3066\u9589\u3058\u308b\u3060\u3051\u306e\u7c21\u6613\u7684\u306a\u3082\u306e\u3060\u304c\u3001\u6027\u80fd\u3092\u51fa\u3059\u305f\u3081\u306b\u306f\u6570\u4ef6\u307e\u3068\u3081\u3066\u51e6\u7406\u3059\u308b\u306a\u3069\u306e\u5de5\u592b\u3092\u3057\u305f\u307b\u3046\u304c\u826f\u3044\u3060\u308d\u3046\u3002
\n\u203b\u30d3\u30eb\u30c9\u3059\u308b\u74b0\u5883\u304b\u3089Kafka Broker\u306e\u540d\u524d\u89e3\u6c7a\u304c\u3067\u304d\u306a\u3044\u3068\u3044\u3051\u306a\u3044\u3053\u3068\u306b\u6ce8\u610f\u304c\u5fc5\u8981\u3002<\/p>\n
package<\/span> com.function<\/span>;<\/span>\r\n\r\nimport<\/span> com.microsoft.azure.functions.ExecutionContext<\/span>;<\/span>\r\nimport<\/span> com.microsoft.azure.functions.HttpMethod<\/span>;<\/span>\r\nimport<\/span> com.microsoft.azure.functions.HttpRequestMessage<\/span>;<\/span>\r\nimport<\/span> com.microsoft.azure.functions.HttpResponseMessage<\/span>;<\/span>\r\nimport<\/span> com.microsoft.azure.functions.HttpStatus<\/span>;<\/span>\r\nimport<\/span> com.microsoft.azure.functions.annotation.AuthorizationLevel<\/span>;<\/span>\r\nimport<\/span> com.microsoft.azure.functions.annotation.FunctionName<\/span>;<\/span>\r\nimport<\/span> com.microsoft.azure.functions.annotation.HttpTrigger<\/span>;<\/span>\r\nimport<\/span> java.util.Optional<\/span>;<\/span>\r\nimport<\/span> org.apache.kafka.clients.producer.KafkaProducer<\/span>;<\/span>\r\nimport<\/span> org.apache.kafka.clients.producer.ProducerRecord<\/span>;<\/span>\r\nimport<\/span> org.apache.kafka.clients.producer.ProducerConfig<\/span>;<\/span>\r\nimport<\/span> org.apache.kafka.clients.admin.AdminClient<\/span>;<\/span>\r\nimport<\/span> org.apache.kafka.clients.admin.DescribeTopicsResult<\/span>;<\/span>\r\nimport<\/span> org.apache.kafka.clients.admin.KafkaAdminClient<\/span>;<\/span>\r\nimport<\/span> org.apache.kafka.clients.CommonClientConfigs<\/span>;<\/span>\r\nimport<\/span> org.apache.kafka.clients.admin.TopicDescription<\/span>;<\/span>\r\nimport<\/span> java.util.Collection<\/span>;<\/span>\r\nimport<\/span> java.util.Collections<\/span>;<\/span>\r\nimport<\/span> java.util.concurrent.ExecutionException<\/span>;<\/span>\r\nimport<\/span> java.util.Properties<\/span>;<\/span>\r\nimport<\/span> java.util.Random<\/span>;<\/span>\r\nimport<\/span> java.io.IOException<\/span>;<\/span>\r\n\r\n\/**\r\n * Azure Functions with HTTP Trigger.\r\n *\/<\/span>\r\npublic<\/span> class<\/span> Function<\/span> {<\/span>\r\n    \/**\r\n     * This function listens at endpoint \"\/api\/FunctionKafkaProducerJava?\". Two ways to invoke it using \"curl\" command in bash:\r\n     * $ curl -XPOST {your host}\/api\/FunctionKafkaProducerJava?name={topicName} -d 'JSONBODY'\r\n     *\/<\/span>\r\n\r\n    @FunctionName<\/span>(<\/span>\"FunctionKafkaProducerJava\"<\/span>)<\/span>\r\n    public<\/span> HttpResponseMessage<\/span> run<\/span>(<\/span>\r\n            @HttpTrigger<\/span>(<\/span>\r\n                name<\/span> =<\/span> \"req\"<\/span>,<\/span>\r\n                methods<\/span> =<\/span> {<\/span>HttpMethod<\/span>.<\/span>GET<\/span>,<\/span> HttpMethod<\/span>.<\/span>POST<\/span>},<\/span>\r\n                authLevel<\/span> =<\/span> AuthorizationLevel<\/span>.<\/span>FUNCTION<\/span>)<\/span>\r\n                HttpRequestMessage<\/span><<\/span>Optional<\/span><<\/span>String<\/span>>><\/span> request<\/span>,<\/span>\r\n            final<\/span> ExecutionContext<\/span> context<\/span>)<\/span> {<\/span>\r\n        context<\/span>.<\/span>getLogger<\/span>().<\/span>info<\/span>(<\/span>\"Java HTTP trigger processed a request.\"<\/span>);<\/span>\r\n\r\n        \/\/ Parse query parameter<\/span>\r\n        final<\/span> String<\/span> topicName<\/span> =<\/span> request<\/span>.<\/span>getQueryParameters<\/span>().<\/span>get<\/span>(<\/span>\"name\"<\/span>);<\/span>\r\n        final<\/span> String<\/span> reqBody<\/span> =<\/span> request<\/span>.<\/span>getBody<\/span>().<\/span>orElse<\/span>(<\/span>\"\"<\/span>);<\/span>\r\n\r\n        \/\/ Set properties used to configure the producer<\/span>\r\n        Properties<\/span> properties<\/span> =<\/span> new<\/span> Properties<\/span>();<\/span>\r\n        properties<\/span>.<\/span>setProperty<\/span>(<\/span>\"bootstrap.servers\"<\/span>,<\/span> \"<KAFKABROKERS>\"<\/span>);<\/span>\r\n        \/\/ Set how to serialize key\/value pairs<\/span>\r\n        properties<\/span>.<\/span>setProperty<\/span>(<\/span>\"key.serializer\"<\/span>,<\/span>\"org.apache.kafka.common.serialization.StringSerializer\"<\/span>);<\/span>\r\n        properties<\/span>.<\/span>setProperty<\/span>(<\/span>\"value.serializer\"<\/span>,<\/span>\"org.apache.kafka.common.serialization.StringSerializer\"<\/span>);<\/span>\r\n\r\n        \/\/ Create Kafka Producer<\/span>\r\n        KafkaProducer<\/span><<\/span>String<\/span>,<\/span> String<\/span>><\/span> producer<\/span> =<\/span> new<\/span> KafkaProducer<\/span><>(<\/span>properties<\/span>);<\/span>\r\n\r\n        \/\/ Send message to Kafka<\/span>\r\n        try<\/span>\r\n        {<\/span>\r\n            producer<\/span>.<\/span>send<\/span>(<\/span>new<\/span> ProducerRecord<\/span><<\/span>String<\/span>,<\/span> String<\/span>>(<\/span>topicName<\/span>,<\/span> reqBody<\/span>)).<\/span>get<\/span>();<\/span>            \r\n        }<\/span>\r\n        catch<\/span> (<\/span>Exception<\/span> e<\/span>)<\/span>\r\n        {<\/span>\r\n            System<\/span>.<\/span>out<\/span>.<\/span>print<\/span>(<\/span>e<\/span>.<\/span>getMessage<\/span>());<\/span>\r\n        }<\/span>\r\n\r\n        \/\/ Close Kafka producer<\/span>\r\n        producer<\/span>.<\/span>flush<\/span>();<\/span>\r\n        producer<\/span>.<\/span>close<\/span>();<\/span>\r\n        return<\/span> request<\/span>.<\/span>createResponseBuilder<\/span>(<\/span>HttpStatus<\/span>.<\/span>OK<\/span>).<\/span>body<\/span>(<\/span>reqBody<\/span>).<\/span>build<\/span>();<\/span>\r\n    }<\/span>\r\n}<\/span>\r\n\r\n<\/code><\/pre>\n
\u6027\u80fd\u9762\u306b\u3064\u3044\u3066\u4e0a\u8a18\u3067\u8ff0\u3079\u305f\u304c\u3001\u4f8b\u3048\u3070\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u9001\u4fe1\u3059\u308b\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u5074\u304b\u3089\u4e00\u56de\u306ePOST\u3067\u30c7\u30fc\u30bf\u3092\u30ea\u30b9\u30c8\u3067\u307e\u3068\u3081\u3066\u9001\u4fe1\u3059\u308b\u3088\u3046\u306b\u3057\u3066\u3001Functions\u5074\u3067\u305d\u308c\u3092\u4e00\u56de\u306eKafka Producer\u306e\u63a5\u7d9a\u3067\u9001\u4fe1\u3059\u308b\u3053\u3068\u3067\u6539\u5584\u3059\u308b\u3068\u3044\u3046\u65b9\u6cd5\u3082\u8003\u3048\u3089\u308c\u308b\u3002<\/p>\n
        \/\/ Create Kafka Producer<\/span>\r\n        KafkaProducer<\/span><<\/span>String<\/span>,<\/span> String<\/span>><\/span> producer<\/span> =<\/span> new<\/span> KafkaProducer<\/span><>(<\/span>properties<\/span>);<\/span>\r\n\r\n        \/\/ Send message to Kafka<\/span>\r\n        String<\/span> jsonLine<\/span>;<\/span>\r\n        for<\/span> (<\/span>int<\/span> i<\/span>=<\/span>0<\/span>;<\/span> i<\/span> <<\/span> reqBodyArray<\/span>.<\/span>length<\/span>;<\/span> i<\/span>++)<\/span> {<\/span>\r\n            try<\/span> {<\/span>\r\n                producer<\/span>.<\/span>send<\/span>(<\/span>new<\/span> ProducerRecord<\/span><<\/span>String<\/span>,<\/span> String<\/span>>(<\/span>topicName<\/span>,<\/span> reqBodyArray<\/span>[<\/span>i<\/span>])).<\/span>get<\/span>();<\/span>\r\n            }<\/span>\r\n            catch<\/span> (<\/span>Exception<\/span> e<\/span>)<\/span> {<\/span>\r\n                System<\/span>.<\/span>out<\/span>.<\/span>print<\/span>(<\/span>e<\/span>.<\/span>getMessage<\/span>());<\/span>\r\n            }<\/span>\r\n        }<\/span>\r\n        \/\/ Close Kafka producer<\/span>\r\n        producer<\/span>.<\/span>flush<\/span>();<\/span>\r\n        producer<\/span>.<\/span>close<\/span>();<\/span>\r\n<\/code><\/pre>\n
\u9001\u4fe1\u30c6\u30b9\u30c8<\/h2>\n
\u4eca\u56de\u306e\u4f8b\u3067\u306fHTTP Trigger\u3067\u4f5c\u6210\u3057\u3066\u3044\u308b\u305f\u3081\u3001POST\u3067\u30c7\u30fc\u30bf\u3092\u9001\u4fe1\u3059\u308b\u3053\u3068\u3067Functions\u3067\u53d7\u3051\u53d6\u308aKafka\u306b\u9001\u4fe1\u3059\u308b\u3053\u3068\u304c\u3067\u304d\u308b\u3002Functions\u306e\u8a8d\u8a3c\u65b9\u6cd5\u306b\u5408\u308f\u305b\u3066\u30ea\u30af\u30a8\u30b9\u30c8\u3092\u9001\u4fe1\u3057\u305f\u3046\u3048\u3067\u3001Kafka\u5074\u306b\u30c7\u30fc\u30bf\u304c\u9001\u3089\u308c\u3066\u3044\u308b\u3053\u3068\u3092\u78ba\u8a8d\u3067\u304d\u308c\u3070OK\u3002<\/p>\n
curl -XPOST<\/span> {<\/span>your host}<\/span>\/api\/FunctionKafkaProducerJava?name={<\/span>topicName}<\/span> -d<\/span> '{<JSONBODY>}'<\/span>\r\n<\/code><\/pre>\n","protected":false},"excerpt":{"rendered":"
\u306f\u3058\u3081\u306b Azure\u4e0a\u3067PaaS\u3068\u3057\u3066Apache Kafka\u3092\u52d5\u304b\u3059\u5834\u5408\u3001\u30aa\u30d7\u30b7\u30e7\u30f3\u3068\u3057\u3066\u8003\u3048\u3089\u308c\u308b\u306e\u306fEv […]<\/p>\n","protected":false},"author":8,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"class_list":["post-46721","post","type-post","status-publish","format-standard","hentry","category-uncategorized"],"yoast_head":"\n- Blog - Silicon Cloud<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.silicloud.com\/zh\/blog\/46721-2\/\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:description\" content=\"\u306f\u3058\u3081\u306b Azure\u4e0a\u3067PaaS\u3068\u3057\u3066Apache Kafka\u3092\u52d5\u304b\u3059\u5834\u5408\u3001\u30aa\u30d7\u30b7\u30e7\u30f3\u3068\u3057\u3066\u8003\u3048\u3089\u308c\u308b\u306e\u306fEv […]\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.silicloud.com\/zh\/blog\/46721-2\/\" \/>\n<meta property=\"og:site_name\" content=\"Blog - Silicon Cloud\" \/>\n<meta property=\"article:published_time\" content=\"2023-08-19T20:29:09+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2024-05-04T04:10:35+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d665e37434c4406d0a0cc\/3-0.png\" \/>\n<meta name=\"author\" content=\"\u96c5, \u609f\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"\u96c5, \u609f\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"4 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/46721-2\/\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/46721-2\/\",\"name\":\"- Blog - Silicon Cloud\",\"isPartOf\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\"},\"datePublished\":\"2023-08-19T20:29:09+00:00\",\"dateModified\":\"2024-05-04T04:10:35+00:00\",\"author\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/f044a4b7fa4ee2701702942002419ca6\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.silicloud.com\/zh\/blog\/46721-2\/\"]}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/\",\"name\":\"Blog - Silicon Cloud\",\"description\":\"\",\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/f044a4b7fa4ee2701702942002419ca6\",\"name\":\"\u96c5, \u609f\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/secure.gravatar.com\/avatar\/e71a913e914f1aad1efc391f92084294bac54bc782acd289638580134cf667a6?s=96&d=mm&r=g\",\"contentUrl\":\"https:\/\/secure.gravatar.com\/avatar\/e71a913e914f1aad1efc391f92084294bac54bc782acd289638580134cf667a6?s=96&d=mm&r=g\",\"caption\":\"\u96c5, \u609f\"},\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/author\/yawu\/\"},{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/46721-2\/#local-main-organization-logo\",\"url\":\"\",\"contentUrl\":\"\",\"caption\":\"Blog - Silicon Cloud\"}]}<\/script>\n<!-- \/ Yoast SEO Premium plugin. -->","yoast_head_json":{"title":"- Blog - Silicon Cloud","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.silicloud.com\/zh\/blog\/46721-2\/","og_locale":"zh_CN","og_type":"article","og_description":"\u306f\u3058\u3081\u306b Azure\u4e0a\u3067PaaS\u3068\u3057\u3066Apache Kafka\u3092\u52d5\u304b\u3059\u5834\u5408\u3001\u30aa\u30d7\u30b7\u30e7\u30f3\u3068\u3057\u3066\u8003\u3048\u3089\u308c\u308b\u306e\u306fEv […]","og_url":"https:\/\/www.silicloud.com\/zh\/blog\/46721-2\/","og_site_name":"Blog - Silicon Cloud","article_published_time":"2023-08-19T20:29:09+00:00","article_modified_time":"2024-05-04T04:10:35+00:00","og_image":[{"url":"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d665e37434c4406d0a0cc\/3-0.png"}],"author":"\u96c5, \u609f","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"\u96c5, \u609f","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"4 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.silicloud.com\/zh\/blog\/46721-2\/","url":"https:\/\/www.silicloud.com\/zh\/blog\/46721-2\/","name":"- Blog - Silicon Cloud","isPartOf":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website"},"datePublished":"2023-08-19T20:29:09+00:00","dateModified":"2024-05-04T04:10:35+00:00","author":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/f044a4b7fa4ee2701702942002419ca6"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.silicloud.com\/zh\/blog\/46721-2\/"]}]},{"@type":"WebSite","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website","url":"https:\/\/www.silicloud.com\/zh\/blog\/","name":"Blog - Silicon Cloud","description":"","inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/f044a4b7fa4ee2701702942002419ca6","name":"\u96c5, \u609f","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/","url":"https:\/\/secure.gravatar.com\/avatar\/e71a913e914f1aad1efc391f92084294bac54bc782acd289638580134cf667a6?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/e71a913e914f1aad1efc391f92084294bac54bc782acd289638580134cf667a6?s=96&d=mm&r=g","caption":"\u96c5, \u609f"},"url":"https:\/\/www.silicloud.com\/zh\/blog\/author\/yawu\/"},{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/46721-2\/#local-main-organization-logo","url":"","contentUrl":"","caption":"Blog - Silicon Cloud"}]}},"_links":{"self":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46721","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/users\/8"}],"replies":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/comments?post=46721"}],"version-history":[{"count":2,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46721\/revisions"}],"predecessor-version":[{"id":98238,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46721\/revisions\/98238"}],"wp:attachment":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/media?parent=46721"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/categories?post=46721"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/tags?post=46721"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}