File tree Expand file tree Collapse file tree 1 file changed +1
-6
lines changed
test/Confluent.Kafka.IntegrationTests/Tests Expand file tree Collapse file tree 1 file changed +1
-6
lines changed Original file line number Diff line number Diff line change @@ -171,13 +171,11 @@ public void ConsumerBuilder_SetStatisticsHandler(string bootstrapServers)
171
171
{
172
172
consumer . Subscribe ( singlePartitionTopic ) ;
173
173
174
- int msgCnt = 0 ;
175
174
while ( true )
176
175
{
177
176
var record = consumer . Consume ( TimeSpan . FromMilliseconds ( 100 ) ) ;
178
177
if ( record == null ) { continue ; }
179
178
if ( record . IsPartitionEOF ) { break ; }
180
- msgCnt += 1 ;
181
179
}
182
180
183
181
Assert . True ( mres1 . Wait ( TimeSpan . FromSeconds ( 5 ) ) ) ;
@@ -218,12 +216,9 @@ public void ConsumerBuilder_SetErrorHandler(string bootstrapServers)
218
216
{
219
217
consumer . Subscribe ( singlePartitionTopic ) ;
220
218
221
- int msgCnt = 0 ;
222
219
while ( ! errorHandler1Called && ! errorHandler2Called )
223
220
{
224
- var record = consumer . Consume ( TimeSpan . FromMilliseconds ( 100 ) ) ;
225
- if ( record == null ) { continue ; }
226
- msgCnt += 1 ;
221
+ consumer . Consume ( TimeSpan . FromMilliseconds ( 100 ) ) ;
227
222
}
228
223
229
224
consumer . Close ( ) ;
You can’t perform that action at this time.
0 commit comments