@@ -770,7 +770,7 @@ public async Task<DeliveryResult<TKey, TValue>> ProduceAsync(
770
770
{
771
771
Headers headers = message . Headers ?? new Headers ( ) ;
772
772
773
- ReadOnlyMemory < byte > ? keyBytes = null ;
773
+ ReadOnlyMemory < byte > ? keyBytes ;
774
774
try
775
775
{
776
776
if ( keySerializer != null )
@@ -791,6 +791,10 @@ public async Task<DeliveryResult<TKey, TValue>> ProduceAsync(
791
791
{
792
792
keyBytes = readOnlyMemory ;
793
793
}
794
+ else // Nullable Memory<byte>
795
+ {
796
+ keyBytes = null ;
797
+ }
794
798
}
795
799
catch ( Exception ex )
796
800
{
@@ -804,7 +808,7 @@ public async Task<DeliveryResult<TKey, TValue>> ProduceAsync(
804
808
ex ) ;
805
809
}
806
810
807
- ReadOnlyMemory < byte > ? valBytes = null ;
811
+ ReadOnlyMemory < byte > ? valBytes ;
808
812
try
809
813
{
810
814
if ( valueSerializer != null )
@@ -825,6 +829,10 @@ public async Task<DeliveryResult<TKey, TValue>> ProduceAsync(
825
829
{
826
830
valBytes = readOnlyMemory ;
827
831
}
832
+ else // Nullable Memory<byte>
833
+ {
834
+ valBytes = null ;
835
+ }
828
836
}
829
837
catch ( Exception ex )
830
838
{
@@ -923,7 +931,7 @@ public void Produce(
923
931
924
932
Headers headers = message . Headers ?? new Headers ( ) ;
925
933
926
- ReadOnlyMemory < byte > ? keyBytes = null ;
934
+ ReadOnlyMemory < byte > ? keyBytes ;
927
935
try
928
936
{
929
937
if ( keySerializer != null )
@@ -943,6 +951,10 @@ public void Produce(
943
951
{
944
952
keyBytes = readOnlyMemory ;
945
953
}
954
+ else // Nullable Memory<byte>
955
+ {
956
+ keyBytes = null ;
957
+ }
946
958
}
947
959
catch ( Exception ex )
948
960
{
@@ -956,7 +968,7 @@ public void Produce(
956
968
ex ) ;
957
969
}
958
970
959
- ReadOnlyMemory < byte > ? valBytes = null ;
971
+ ReadOnlyMemory < byte > ? valBytes ;
960
972
try
961
973
{
962
974
if ( valueSerializer != null )
@@ -976,6 +988,10 @@ public void Produce(
976
988
{
977
989
valBytes = readOnlyMemory ;
978
990
}
991
+ else // Nullable Memory<byte>
992
+ {
993
+ valBytes = null ;
994
+ }
979
995
}
980
996
catch ( Exception ex )
981
997
{
0 commit comments