Skip to content

Commit 30146df

Browse files
committed
nit
1 parent 12adab1 commit 30146df

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

test/Confluent.Kafka.IntegrationTests/Tests/Producer_ProduceAsync_Error.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -106,7 +106,7 @@ public void Producer_ProduceAsync_Error(string bootstrapServers)
106106
Assert.Equal(TimestampType.NotAvailable, dr.Message.Timestamp.Type);
107107
}
108108

109-
// byte[] case
109+
// Memory<byte> case
110110

111111
Task<DeliveryResult<ReadOnlyMemory<byte>, Memory<byte>>> drt3;
112112
using (var producer = new TestProducerBuilder<ReadOnlyMemory<byte>, Memory<byte>>(producerConfig).Build())

test/Confluent.Kafka.IntegrationTests/Tests/SimpleProduceConsume.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -117,7 +117,7 @@ private static DeliveryResult<Null, string> ProduceMessage(string topic, IProduc
117117

118118
private static DeliveryResult<Null, Memory<byte>?> ProduceMessage(string topic, IProducer<Null, Memory<byte>?> producer, string testString)
119119
{
120-
var result = producer .ProduceAsync(topic, new Message<Null, Memory<byte>?>
120+
var result = producer.ProduceAsync(topic, new Message<Null, Memory<byte>?>
121121
{
122122
Value = testString == null ? null : Encoding.UTF8.GetBytes(testString),
123123
}).Result;

0 commit comments

Comments
 (0)