org.apache.kafka.clients.consumer.internals

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethodsMissedClasses
Total19,604 of 19,6040%1,781 of 1,7810%1,5131,5133,9593,9596176177777
Fetcher2,8680%2680%194194572572585811
AbstractStickyAssignor2,2120%2520%157157423423313111
ConsumerCoordinator2,1830%2190%150150476476404011
SubscriptionState1,3330%1510%161161282282848411
AbstractCoordinator1,2670%1260%112112287287494911
ConsumerNetworkClient7770%720%7171187187353511
Fetcher.FetchManagerMetrics6250%200%20209494101011
Fetcher.CompletedFetch5430%700%4747119119121211
FetcherMetricsRegistry4540%n/a4441414411
AbstractStickyAssignor.PartitionMovements4490%580%39398585101011
SubscriptionState.TopicPartitionState4000%480%6161111111373711
AbstractCoordinator.JoinGroupResponseHandler3610%420%232367672211
ConsumerProtocol3570%320%30307171141411
ConsumerCoordinator.OffsetCommitResponseHandler3330%440%242466662211
AbstractCoordinator.HeartbeatThread3110%240%191970707711
AbstractCoordinator.GroupCoordinatorMetrics3000%40%5537373311
AbstractCoordinator.SyncGroupResponseHandler2760%300%171754542211
Fetcher.new RequestFutureListener() {...}2570%120%9942423311
ConsumerCoordinator.OffsetFetchResponseHandler2430%260%151550502211
RequestFuture2430%280%36366666222211
Heartbeat2390%40%17175656151511
ConsumerNetworkClient.UnsentRequests2140%260%25254747121211
OffsetsForLeaderEpochClient2090%150%141446465511
AbstractCoordinator.HeartbeatResponseHandler1880%200%121234342211
ConsumerCoordinator.ConsumerCoordinatorMetrics1690%n/a2218182211
KafkaConsumerMetrics1580%40%7728285511
AbstractPartitionAssignor1410%120%121225256611
AbstractCoordinator.FindCoordinatorResponseHandler1340%80%7729293311
AbstractCoordinator.Generation1120%140%131315156611
Fetcher.new RequestFutureListener() {...}1070%80%7716163311
Fetcher.new RequestFutureListener() {...}1070%80%7719193311
Fetcher.new RequestFutureListener() {...}1040%60%7719194411
Fetcher.FetchResponseMetricAggregator1040%60%5522222211
SubscriptionState.FetchPosition1030%120%111115155511
AbstractStickyAssignor.ConsumerPair1030%160%131320205511
ConsumerMetadata950%120%121224246611
ConsumerNetworkClient.RequestFutureCompletionHandler880%80%8821214411
AbstractPartitionAssignor.MemberInfo830%120%111117175511
ConsumerInterceptors790%60%8826265511
Fetcher.new RequestFutureListener() {...}750%60%6614143311
AsyncClient.new RequestFutureAdapter() {...}720%0%4416163311
AbstractCoordinator.HeartbeatThread.new RequestFutureListener() {...}710%40%5515153311
ConsumerCoordinator.new RequestFutureListener() {...}700%60%6612123311
ConsumerCoordinator.MetadataSnapshot680%80%7712123311
SubscriptionState.LogTruncation660%0%3322222211
AbstractCoordinator.LeaveGroupResponseHandler600%40%4413132211
AbstractCoordinator.MemberState560%40%44662211
AbstractCoordinator.CoordinatorResponseHandler550%40%6617174411
ConsumerCoordinator.new RequestFutureListener() {...}520%n/a33883311
ConsumerMetrics470%n/a4412124411
SubscriptionState.SubscriptionType440%n/a11221111
SubscriptionState.FetchStates440%n/a11551111
AbstractStickyAssignor.PartitionComparator400%40%44992211
AsyncClient330%n/a33773311
ConsumerCoordinator.PendingCommittedOffsetRequest300%40%44662211
AbstractStickyAssignor.TopicComparator280%0%33772211
AbstractStickyAssignor.SubscriptionComparator280%0%33772211
Fetcher.new RequestFutureAdapter() {...}270%n/a22552211
RequestFuture.new RequestFutureListener() {...}260%n/a33553311
SubscriptionState.FetchStates.new SubscriptionState.FetchStates() {...}260%n/a44444411
SubscriptionState.FetchStates.new SubscriptionState.FetchStates() {...}260%n/a44444411
SubscriptionState.FetchStates.new SubscriptionState.FetchStates() {...}260%n/a44444411
ConsumerCoordinator.OffsetCommitCompletion0%0%33882211
SubscriptionState.FetchStates.new SubscriptionState.FetchStates() {...}0%n/a44444411
Fetcher.ListOffsetResult0%n/a22882211
AbstractCoordinator.new RequestFutureListener() {...}0%n/a33663311
RequestFuture.new RequestFutureListener() {...}0%n/a33553311
ConsumerCoordinator.DefaultOffsetCommitCallback0%0%33442211
OffsetsForLeaderEpochClient.OffsetForEpochResult0%n/a33663311
Fetcher.FetchResponseMetricAggregator.FetchMetrics0%n/a11331111
Fetcher.ListOffsetData0%n/a11551111
SubscriptionState.FetchState0%0%22331111
AbstractStickyAssignor.ConsumerGenerationPair0%n/a11441111
AbstractStickyAssignor.MemberData0%n/a11441111
RequestFutureAdapter0%n/a22332211
NoOpConsumerRebalanceListener0%n/a33333311
NoAvailableBrokersException0%n/a11111111