Skip to content

Commit 3968ce2

Browse files
HansDamgaard1970mhowlett
authored andcommitted
PersistenceStatus not set correctly (#806)
1 parent 0747e6b commit 3968ce2

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

src/Confluent.Kafka/Producer.cs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -196,6 +196,7 @@ private void DeliveryReportCallbackImpl(IntPtr rk, IntPtr rkmessage, IntPtr opaq
196196
Partition = msg.partition,
197197
Offset = msg.offset,
198198
Error = KafkaHandle.CreatePossiblyFatalError(msg.err, null),
199+
PersistenceStatus = messageStatus,
199200
Message = new Message<Null, Null> { Timestamp = new Timestamp(timestamp, (TimestampType)timestampType), Headers = headers }
200201
}
201202
);
@@ -931,6 +932,7 @@ public void HandleDeliveryReport(DeliveryReport<Null, Null> deliveryReport)
931932
var dr = new DeliveryResult<K, V>
932933
{
933934
TopicPartitionOffset = deliveryReport.TopicPartitionOffset,
935+
PersistenceStatus = deliveryReport.PersistenceStatus,
934936
Message = new Message<K, V>
935937
{
936938
Key = Key,
@@ -993,6 +995,7 @@ public void HandleDeliveryReport(DeliveryReport<Null, Null> deliveryReport)
993995
var dr = new DeliveryReport<K, V>
994996
{
995997
TopicPartitionOffsetError = deliveryReport.TopicPartitionOffsetError,
998+
PersistenceStatus = deliveryReport.PersistenceStatus,
996999
Message = new Message<K, V>
9971000
{
9981001
Key = Key,

0 commit comments

Comments
 (0)