From fac4ffda9a7078e13849055b2db5c355b749d46f Mon Sep 17 00:00:00 2001 From: Stefan Bocutiu Date: Thu, 14 Nov 2024 14:37:01 +0000 Subject: [PATCH] Fix the error to correctly use FlushInterval (#166) Co-authored-by: stheppi --- .../cloud/common/sink/config/CloudSinkBucketOptions.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka-connect-cloud-common/src/main/scala/io/lenses/streamreactor/connect/cloud/common/sink/config/CloudSinkBucketOptions.scala b/kafka-connect-cloud-common/src/main/scala/io/lenses/streamreactor/connect/cloud/common/sink/config/CloudSinkBucketOptions.scala index 420e45d4b..d3a1c8586 100644 --- a/kafka-connect-cloud-common/src/main/scala/io/lenses/streamreactor/connect/cloud/common/sink/config/CloudSinkBucketOptions.scala +++ b/kafka-connect-cloud-common/src/main/scala/io/lenses/streamreactor/connect/cloud/common/sink/config/CloudSinkBucketOptions.scala @@ -45,7 +45,7 @@ object CloudSinkBucketOptions extends LazyLogging { | |Replace WITH_FLUSH_COUNT with: PROPERTIES('${FlushCount.entryName}'=123). |Replace WITH_FLUSH_SIZE with: PROPERTIES('${FlushSize.entryName}'=456). - |Replace WITH_FLUSH_Interval with: PROPERTIES('${FlushInterval}'=789).""".stripMargin + |Replace WITH_FLUSH_Interval with: PROPERTIES('${FlushInterval.entryName}'=789).""".stripMargin val WithPartitionerError = s""" |Invalid KCQL setting. WITHPARTITIONER feature has been replaced.