From 85457d0c6bec646c879f943921ead5a0eb4896fc Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9F=B3=E4=B8=8B?= Date: Mon, 22 Jul 2024 11:27:23 +0800 Subject: [PATCH] add kafka --- kafka-sink-connector/publish.yaml | 2 +- kafka-sink-connector/src/sink/requirements.txt | 6 +++--- kafka-sink-connector/src/transform/requirements.txt | 2 +- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/kafka-sink-connector/publish.yaml b/kafka-sink-connector/publish.yaml index 8619dfb..5006e73 100644 --- a/kafka-sink-connector/publish.yaml +++ b/kafka-sink-connector/publish.yaml @@ -2,7 +2,7 @@ Type: Application Name: KafkaSinkConnector Provider: - 阿里云 -Version: 0.0.15 +Version: 0.0.16 Description: 基于函数计算实现的 kafka proxy，通过 SDK Invoke Function 的方式将消息传递至 Kafka 特定 Topic HomePage: https://github.com/devsapp/serverless-big-data Tags: diff --git a/kafka-sink-connector/src/sink/requirements.txt b/kafka-sink-connector/src/sink/requirements.txt index e3a0ed7..a9a7015 100644 --- a/kafka-sink-connector/src/sink/requirements.txt +++ b/kafka-sink-connector/src/sink/requirements.txt @@ -1,3 +1,3 @@ -schema -confluent-kafka -retrying \ No newline at end of file +schema==0.7.5 +confluent-kafka==2.3.0 +retrying==1.3.4 \ No newline at end of file diff --git a/kafka-sink-connector/src/transform/requirements.txt b/kafka-sink-connector/src/transform/requirements.txt index 2c483a2..094cbe5 100644 --- a/kafka-sink-connector/src/transform/requirements.txt +++ b/kafka-sink-connector/src/transform/requirements.txt @@ -1 +1 @@ -schema \ No newline at end of file +schema==0.7.5 \ No newline at end of file