Skip to content

Commit eaa7ee1

Browse files
committed
fix: kafka keys might be null
1 parent 5c41a5b commit eaa7ee1

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

kaftor/src/commonMain/kotlin/Declarations.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,7 @@ sealed interface KafkaRecord {
9999
val timestampType: TimestampType
100100
val serializedKeySize: Int
101101
val serializedValueSize: Int
102-
val key: String
102+
val key: String?
103103
val value: ByteBuffer
104104
val headers: Headers
105105
val leaderEpoch: Int?

kaftor/src/commonMain/kotlin/internal.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,7 @@ private data class KafkaRecordImpl(
9393
override val timestampType: TimestampType,
9494
override val serializedKeySize: Int,
9595
override val serializedValueSize: Int,
96-
override val key: String,
96+
override val key: String?,
9797
override val value: ByteBuffer,
9898
override val headers: Headers,
9999
override val leaderEpoch: Int?,

0 commit comments

Comments
 (0)