Google Functons получает сообщение от Kafka через spring-cloud-stream и spring-cloud-functions

Я знаю, что с помощью Kafka Connect вы можете создать коннектор, переводящий все сообщения kafka в тему PUBSUB.

Я хотел бы знать, могу ли я использовать связыватели Spring Cloud Stream в сочетании с Spring Cloud Function и развернуть все это в Google Functions.

Насколько я понимаю, я могу комбинировать Spring Cloud Stream и Spring Cloud Function. Означает ли это, что я могу использовать связыватель из Spring Cloud Stream, чтобы действительно принимать сообщение от Kafka?


google-cloud-functions apache-kafka spring-cloud-stream spring-cloud-stream-binder-kafka spring-cloud-function
person Alexander Petrov    schedule 07.09.2020    source источник
comment
О развертывании этого в Google Cloud Functions да, это возможно, как упоминалось здесь с использованием среды выполнения Java11 для GCF   -  person Soni Sol    schedule 08.09.2020
comment
@ JoséSoní Я не думаю, что вы понимаете вопрос. Вопрос не в том, смогу ли я развернуть облачные функции sring в GCF. Ясно, что могу, вопрос в том, могу ли я создать бинд KAFKA через spring-cloud-stream вместе с spring-cloud-function и развернуть его в GCF. Идея в том, что тогда мне, возможно, не нужен триггер PUBSUB, и мой KAFKa напрямую обращается к моей функции.   -  person Alexander Petrov    schedule 08.09.2020

Ответы (1)


arrow_upward
2
arrow_downward

Google Cloud Functions использует модель триггера для запуска функций в spring -cloud-function. Кафка как триггер не поддерживается.

Обходной путь - создать использование Kafka Connect для подачи PUBSUB из темы Kafka. Вы можете создать свой собственный: https://dev.to/vtatai/make-kafka-serverless-by-connecting-it-to-google-cloud-functions-2ahh

Или используйте прилагаемый: https://github.com/GoogleCloudPlatform/pubsub/tree/master/kafka-connector

person Alexander Petrov    schedule 16.09.2020