MockConsumer

Source file "org/apache/kafka/clients/consumer/MockConsumer.java" was not found during generation of report.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,061 of 1,0610%78 of 780%1101102532537171
poll(Duration)2010%240%1313373711
subscribe(Pattern, ConsumerRebalanceListener)930%100%66191911
MockConsumer(OffsetResetStrategy)620%n/a11141411
beginningOffsets(Collection)550%60%44121211
endOffsets(Collection)550%60%44121211
resetOffsetPosition(TopicPartition)480%80%55121211
addRecord(ConsumerRecord)350%20%228811
updateFetchPosition(TopicPartition)330%40%337711
position(TopicPartition)300%40%338811
commitAsync(Map, OffsetCommitCallback)290%40%336611
pause(Collection)210%20%225511
resume(Collection)210%20%225511
currentLag(TopicPartition)200%20%223311
committed(Set)180%n/a114411
lambda$committed$4(TopicPartition)160%20%222211
subscribe(Collection, ConsumerRebalanceListener)150%n/a114411
assign(Collection)140%n/a114411
schedulePollTask(Runnable)140%n/a114411
unsubscribe()90%n/a114411
commitAsync(OffsetCommitCallback)90%n/a113311
seek(TopicPartition, OffsetAndMetadata)90%n/a113311
partitionsFor(String)90%n/a112211
updatePartitions(String, List)90%n/a113311
ensureNotClosed()90%20%223311
rebalance(Collection)80%n/a113311
seek(TopicPartition, long)80%n/a113311
committed(TopicPartition)80%n/a111111
seekToBeginning(Collection)80%n/a113311
seekToEnd(Collection)80%n/a113311
groupMetadata()80%n/a111111
subscribe(Collection)70%n/a112211
subscribe(Pattern)70%n/a112211
paused()70%n/a111111
lambda$poll$1(TopicPartition)70%n/a111111
commitSync()60%n/a112211
commitSync(Duration)60%n/a112211
poll(long)50%n/a111111
commitSync(Map)50%n/a112211
updateBeginningOffsets(Map)50%n/a112211
updateEndOffsets(Map)50%n/a112211
listTopics()50%n/a112211
offsetsForTimes(Map)50%n/a111111
close()50%n/a112211
wakeup()50%n/a112211
assignment()40%n/a111111
subscription()40%n/a111111
setException(KafkaException)40%n/a112211
setPollException(KafkaException)40%n/a112211
setOffsetsException(KafkaException)40%n/a112211
commitAsync()40%n/a112211
commitSync(Map, Duration)40%n/a112211
committed(TopicPartition, Duration)40%n/a111111
committed(Set, Duration)40%n/a111111
position(TopicPartition, Duration)40%n/a111111
metrics()40%n/a112211
close(Duration)40%n/a112211
scheduleNopPollTask()40%n/a112211
partitionsFor(String, Duration)40%n/a111111
offsetsForTimes(Map, Duration)40%n/a111111
beginningOffsets(Collection, Duration)40%n/a111111
endOffsets(Collection, Duration)40%n/a111111
enforceRebalance()40%n/a112211
resetShouldRebalance()40%n/a112211
lambda$addRecord$2(TopicPartition)40%n/a111111
lambda$poll$0(TopicPartition)40%n/a111111
closed()30%n/a111111
listTopics(Duration)30%n/a111111
shouldRebalance()30%n/a111111
lastPollTimeout()30%n/a111111
lambda$committed$3(TopicPartition)20%n/a111111
lambda$scheduleNopPollTask$5()0%n/a111111