Я создаю функцию Azure, используя триггер Kafka с Java, чтобы потреблять данные из кластера Kafka.
На самом деле я получаю эту ошибку. < /p>
Microsoft.Azure.WebJobs.Host: Error indexing method Functions.KafkaTriggerReceiveResponse. Microsoft.Azure.WebJobs.Extensions.Kafka: is not a valid file location
< /code>
¿Как я ссылаюсь на путь сертификатов? Для параметров sslcertificatelocation, sslkeylocation. < /P>
@KafkaTrigger(
name = "kafkaMeetingTrigger",
topic = "topicName",
brokerList = "%BrokerList%",
cardinality = Cardinality.ONE,
sslCertificateLocation = "%KafkaCertPath%",
sslKeyLocation = "%KafkaCertPath%",
protocol = BrokerProtocol.SSL,
dataType = "binary",
consumerGroup="%ConsumerGroup%") byte[] kafkaEventData,
Подробнее здесь: https://stackoverflow.com/questions/795 ... cates-path
