Skip to content

Commit 6256854

Browse files
committed
[ksqlDb.RestApi.Client]: IgnoreAttribute added to pseudo columns in the Record type in a backward compatible way
1 parent 96738ea commit 6256854

File tree

2 files changed

+8
-3
lines changed
  • Tests/ksqlDB.RestApi.Client.IntegrationTests/Models
  • ksqlDb.RestApi.Client/KSql/Query

2 files changed

+8
-3
lines changed
Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,10 @@
1-
using ksqlDB.RestApi.Client.KSql.RestApi.Statements.Annotations;
1+
using ksqlDB.RestApi.Client.KSql.RestApi.Statements.Annotations;
22

33
namespace ksqlDb.RestApi.Client.IntegrationTests.Models;
44

55
public record Record
66
{
7-
[IgnoreByInserts]
7+
[ksqlDB.RestApi.Client.KSql.RestApi.Statements.Annotations.Ignore]
8+
[PseudoColumn]
89
public long RowTime { get; set; }
9-
}
10+
}

ksqlDb.RestApi.Client/KSql/Query/Record.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@ public class Record
1010
/// <summary>
1111
/// Columns that are populated by the Kafka record's header.
1212
/// </summary>
13+
[Ignore]
1314
[IgnoreByInserts]
1415
[PseudoColumn]
1516
[Obsolete("This property will be removed in the future. Headers need to be defined per use case and should have the type ARRAY<STRUCT<key STRING, value BYTES>>.")]
@@ -18,20 +19,23 @@ public class Record
1819
/// <summary>
1920
/// The offset of the source record.
2021
/// </summary>
22+
[Ignore]
2123
[IgnoreByInserts]
2224
[PseudoColumn]
2325
public long? RowOffset { get; set; }
2426

2527
/// <summary>
2628
/// The partition of the source record.
2729
/// </summary>
30+
[Ignore]
2831
[IgnoreByInserts]
2932
[PseudoColumn]
3033
public short? RowPartition { get; set; }
3134

3235
/// <summary>
3336
/// Row timestamp, inferred from the underlying Kafka record if not overridden.
3437
/// </summary>
38+
[Ignore]
3539
[IgnoreByInserts]
3640
[PseudoColumn]
3741
public long RowTime { get; set; }

0 commit comments

Comments
 (0)