File tree Expand file tree Collapse file tree 2 files changed +25
-1
lines changed
Samples/ksqlDB.RestApi.Client.Sample Expand file tree Collapse file tree 2 files changed +25
-1
lines changed Original file line number Diff line number Diff line change @@ -34,6 +34,19 @@ public async Task InitModelAndCreateStreamAsync(CancellationToken cancellationTo
34
34
. Property ( c => c . Header )
35
35
. WithHeader ( header ) ;
36
36
37
+ modelBuilder . Entity < Record > ( )
38
+ . Property ( b => b . Headers )
39
+ . AsStruct ( )
40
+ . WithHeaders ( ) ;
41
+
42
+ modelBuilder . Entity < KeyValuePair > ( )
43
+ . Property ( c => c . Key )
44
+ . HasColumnName ( nameof ( KeyValuePair . Key ) . ToUpper ( ) ) ;
45
+
46
+ modelBuilder . Entity < KeyValuePair > ( )
47
+ . Property ( c => c . Value )
48
+ . HasColumnName ( nameof ( KeyValuePair . Value ) . ToUpper ( ) ) ;
49
+
37
50
var restApiProvider = ConfigureRestApiClientWithServicesCollection ( new ServiceCollection ( ) , modelBuilder ) ;
38
51
39
52
var entityCreationMetadata = new EntityCreationMetadata ( kafkaTopic : nameof ( Payment ) , partitions : 1 ) ;
@@ -94,3 +107,14 @@ record PocoWithHeader
94
107
{
95
108
public byte [ ] Header { get ; init ; } = null ! ;
96
109
}
110
+
111
+ record KeyValuePair
112
+ {
113
+ public string Key { get ; set ; } = null ! ;
114
+ public byte [ ] Value { get ; set ; } = null ! ;
115
+ }
116
+
117
+ record Record
118
+ {
119
+ public KeyValuePair [ ] Headers { get ; init ; } = null ! ;
120
+ }
Original file line number Diff line number Diff line change 9
9
</PropertyGroup >
10
10
11
11
<ItemGroup >
12
- <PackageReference Include =" ksqlDb.RestApi.Client" Version =" 6.2.0 " />
12
+ <PackageReference Include =" ksqlDb.RestApi.Client" Version =" 6.3.0-rc.1 " />
13
13
<!-- <ProjectReference Include="..\..\ksqlDb.RestApi.Client\ksqlDb.RestApi.Client.csproj" /> -->
14
14
<!-- <PackageReference Include="ksqlDb.RestApi.Client.ProtoBuf" Version="4.0.0" /> -->
15
15
<ProjectReference Include =" ..\..\ksqlDb.RestApi.Client.ProtoBuf\ksqlDb.RestApi.Client.ProtoBuf.csproj" />
You can’t perform that action at this time.
0 commit comments