Skip to content

Commit f24b78a

Browse files
Mousavi310mhowlett
authored andcommitted
Fix mistaken assert in PartitionEOF. (#852)
* Fix mistaken assert in PartitionEOF.
1 parent 6cfb033 commit f24b78a

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

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

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -60,8 +60,8 @@ public void Consumer_PartitionEOF(string bootstrapServers)
6060
Assert.NotNull(cr1.Message);
6161
Assert.False(cr1.IsPartitionEOF);
6262
var cr2 = consumer.Consume();
63-
Assert.NotNull(cr1.Message);
64-
Assert.False(cr1.IsPartitionEOF);
63+
Assert.NotNull(cr2.Message);
64+
Assert.False(cr2.IsPartitionEOF);
6565
var cr3 = consumer.Consume(TimeSpan.FromSeconds(1));
6666
Assert.Null(cr3);
6767

@@ -85,8 +85,8 @@ public void Consumer_PartitionEOF(string bootstrapServers)
8585
Assert.NotNull(cr1.Message);
8686
Assert.False(cr1.IsPartitionEOF);
8787
var cr2 = consumer.Consume();
88-
Assert.NotNull(cr1.Message);
89-
Assert.False(cr1.IsPartitionEOF);
88+
Assert.NotNull(cr2.Message);
89+
Assert.False(cr2.IsPartitionEOF);
9090
var cr3 = consumer.Consume(TimeSpan.FromSeconds(1));
9191
Assert.Null(cr3);
9292

@@ -117,8 +117,8 @@ public void Consumer_PartitionEOF(string bootstrapServers)
117117
Assert.NotNull(cr1.Message);
118118
Assert.False(cr1.IsPartitionEOF);
119119
var cr2 = consumer.Consume();
120-
Assert.NotNull(cr1.Message);
121-
Assert.False(cr1.IsPartitionEOF);
120+
Assert.NotNull(cr2.Message);
121+
Assert.False(cr2.IsPartitionEOF);
122122
var cr3 = consumer.Consume();
123123
Assert.Null(cr3.Message);
124124
Assert.True(cr3.IsPartitionEOF);
@@ -145,8 +145,8 @@ public void Consumer_PartitionEOF(string bootstrapServers)
145145
Assert.NotNull(cr1.Message);
146146
Assert.False(cr1.IsPartitionEOF);
147147
var cr2 = consumer.Consume();
148-
Assert.NotNull(cr1.Message);
149-
Assert.False(cr1.IsPartitionEOF);
148+
Assert.NotNull(cr2.Message);
149+
Assert.False(cr2.IsPartitionEOF);
150150
var cr3 = consumer.Consume();
151151
Assert.Null(cr3.Message);
152152
Assert.True(cr3.IsPartitionEOF);

0 commit comments

Comments
 (0)