[ksqlDB.RestApi.Client]: separated configuration for pull and push qu…

…eries. Added SetupPullQuery configuration option sample.
tomasfabian · Apr 26, 2024 · e569a0b · e569a0b
1 parent 9b6c8a6
commit e569a0b
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/Samples/ksqlDB.RestApi.Client.Sample/Program.cs b/Samples/ksqlDB.RestApi.Client.Sample/Program.cs
@@ -58,10 +58,9 @@ public static KSqlDBContextOptions CreateQueryStreamOptions(string ksqlDbUrl)
         //SetupQueryStream affects only EndpointType.QueryStream
         options.Properties[KSqlDbConfigs.KsqlQueryPushV2Enabled] = "true";
       })
-      .SetupQuery(options =>
+      .SetupPullQuery(options =>
       {
-        //SetupQuery affects only EndpointType.Query
-        options.Properties[KSqlDbConfigs.ProcessingGuarantee] = ProcessingGuarantee.ExactlyOnce.ToKSqlValue();
+        options[KSqlDbConfigs.KsqlQueryPullTableScanEnabled] = "false";
       })
       .Options;
 

diff --git a/Samples/ksqlDB.RestApi.Client.Sample/ksqlDB.RestApi.Client.Samples.csproj b/Samples/ksqlDB.RestApi.Client.Sample/ksqlDB.RestApi.Client.Samples.csproj
@@ -9,7 +9,7 @@
     </PropertyGroup>
 
     <ItemGroup>
-        <!-- <PackageReference Include="ksqlDb.RestApi.Client" Version="5.1.0" /> -->
+        <!-- <PackageReference Include="ksqlDb.RestApi.Client" Version="6.0.0-rc.2" /> -->
         <ProjectReference Include="..\..\ksqlDb.RestApi.Client\ksqlDb.RestApi.Client.csproj" />
         <PackageReference Include="ksqlDb.RestApi.Client.ProtoBuf" Version="3.0.0" />
         <!-- <ProjectReference Include="..\..\ksqlDb.RestApi.Client.ProtoBuf\ksqlDb.RestApi.Client.ProtoBuf.csproj" /> -->