KafkaAdminClient

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

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total4,604 of 4,6040%261 of 2610%246246799799113113
createInternal(AdminClientConfig, KafkaAdminClient.TimeoutProcessorFactory, HostResolver)2100%20%22474711
describeReplicaLogDirs(Collection, DescribeReplicaLogDirsOptions)1840%120%77303011
alterReplicaLogDirs(Map, AlterReplicaLogDirsOptions)1610%100%66272711
alterPartitionReassignments(Map, AlterPartitionReassignmentsOptions)1510%100%66262611
getListOffsetsCalls(MetadataOperationContext, Map, Map)1470%80%55252511
close(Duration)1060%120%77292911
createTopics(Collection, CreateTopicsOptions)1060%80%55191911
createAcls(Collection, CreateAclsOptions)1060%60%44171711
KafkaAdminClient(AdminClientConfig, String, Time, AdminMetadataManager, Metrics, KafkaClient, KafkaAdminClient.TimeoutProcessorFactory, LogContext)1040%20%22222211
describeTopics(Collection, DescribeTopicsOptions)1040%80%55161611
createPartitions(Map, CreatePartitionsOptions)1020%60%44232311
listPartitionReassignments(Optional, ListPartitionReassignmentsOptions)1020%100%66151511
handleDeleteTopicsUsingIds(Collection, DeleteTopicsOptions)1000%80%55181811
handleDeleteTopicsUsingNames(Collection, DeleteTopicsOptions)990%80%55181811
describeConfigs(Collection, DescribeConfigsOptions)990%60%44151511
lambda$alterUserScramCredentials$23(Map, String, Map, UserScramCredentialAlteration)950%120%77181811
alterUserScramCredentials(List, AlterUserScramCredentialsOptions)930%20%22171711
alterConfigs(Map, AlterConfigsOptions, Collection, KafkaAdminClient.NodeProvider)890%40%33121211
deleteAcls(Collection, DeleteAclsOptions)830%40%33131311
logDirDescriptions(DescribeLogDirsResponse)830%60%44131311
deleteRecords(Map, DeleteRecordsOptions)830%40%33121211
updateFeatures(Map, UpdateFeaturesOptions)790%60%44131311
listOffsets(Map, ListOffsetsOptions)740%20%22121211
alterConfigs(Map, AlterConfigsOptions)700%60%44131311
incrementalAlterConfigs(Map, AlterConfigsOptions)700%60%44131311
getMembersFromGroup(String)690%40%33111111
createDelegationToken(CreateDelegationTokenOptions)630%20%22101011
describeLogDirs(Collection, DescribeLogDirsOptions)590%20%229911
alterClientQuotas(Collection, AlterClientQuotasOptions)570%20%227711
describeAcls(AclBindingFilter, DescribeAclsOptions)530%20%228811
describeCluster(DescribeClusterOptions)520%n/a117711
configureDefaultApiTimeoutMs(AdminClientConfig)480%40%33101011
incrementalAlterConfigs(Map, AlterConfigsOptions, Collection, KafkaAdminClient.NodeProvider)470%20%226611
removeMembersFromConsumerGroup(String, RemoveMembersFromConsumerGroupOptions)440%20%228811
createInternal(AdminClientConfig, AdminMetadataManager, KafkaClient, Time)410%n/a118811
lambda$alterUserScramCredentials$20(Map, UserScramCredentialAlteration)380%80%558811
configSource(DescribeConfigsResponse.ConfigSource)370%70%77151511
listConsumerGroups(ListConsumerGroupsOptions)370%n/a115511
deleteTopics(TopicCollection, DeleteTopicsOptions)360%40%335511
describeUserScramCredentials(List, DescribeUserScramCredentialsOptions)360%n/a115511
unregisterBroker(int, UnregisterBrokerOptions)360%n/a115511
newCall(AdminApiDriver, AdminApiDriver.RequestSpec)360%20%223311
renewDelegationToken(byte[], RenewDelegationTokenOptions)350%n/a114411
expireDelegationToken(byte[], ExpireDelegationTokenOptions)350%n/a114411
electLeaders(ElectionType, Set, ElectLeadersOptions)350%n/a114411
describeFeatures(DescribeFeaturesOptions)350%n/a116611
listTopics(ListTopicsOptions)340%n/a114411
describeDelegationToken(DescribeDelegationTokenOptions)340%n/a114411
describeClientQuotas(ClientQuotaFilter, DescribeClientQuotasOptions)340%n/a114411
getScramCredentialUpsertion(UserScramCredentialUpsertion)330%n/a116611
describeConsumerGroups(Collection, DescribeConsumerGroupsOptions)300%n/a116611
lambda$describeConfigResult$8(DescribeConfigsResponseData.DescribeConfigsResourceResult)300%n/a11101011
deleteConsumerGroups(Collection, DeleteConsumerGroupsOptions)280%n/a116611
listConsumerGroupOffsets(String, ListConsumerGroupOffsetsOptions)260%n/a115511
deleteConsumerGroupOffsets(String, Set, DeleteConsumerGroupOffsetsOptions)260%n/a115511
prettyPrintException(Throwable)250%40%335511
alterConsumerGroupOffsets(String, Map, AlterConsumerGroupOffsetsOptions)250%n/a115511
invokeDriver(AdminApiHandler, AdminApiFuture, Integer)250%n/a115511
abortTransaction(AbortTransactionSpec, AbortTransactionOptions)240%n/a115511
describeProducers(Collection, DescribeProducersOptions)220%n/a115511
describeTransactions(Collection, DescribeTransactionsOptions)210%n/a115511
listTransactions(ListTransactionsOptions)210%n/a114411
maybeSendRequests(AdminApiDriver, long)210%20%224411
calcTimeoutMsRemainingAsInt(long, long)200%40%336611
rescheduleMetadataTask(MetadataOperationContext, Supplier)200%n/a115511
generateClientId(AdminClientConfig)190%20%224411
getOffsetFromOffsetSpec(OffsetSpec)190%60%447711
getCreateTopicsCall(CreateTopicsOptions, Map, CreateTopicsRequestData.CreatableTopicCollection, Map, long, long)180%n/a111111
getDeleteTopicsCall(DeleteTopicsOptions, Map, List, Map, long, long)180%n/a111111
getDeleteTopicsWithIdsCall(DeleteTopicsOptions, Map, List, Map, long, long)180%n/a111111
getCreatePartitionsCall(CreatePartitionsOptions, Map, CreatePartitionsRequestData.CreatePartitionsTopicCollection, Map, long, long)180%n/a111111
lambda$maybeCompleteQuotaExceededException$4(Map, int, Object, ThrottlingQuotaExceededException)180%n/a113311
nodeFor(ConfigResource)170%60%444411
calcDeadlineMs(long, Integer)160%20%223311
validAclOperations(int)160%20%227711
getMetadataCall(MetadataOperationContext, Supplier)150%n/a111111
getSubLevelError(Map, Object, String)150%20%223311
lambda$describeConfigs$5(ConfigResource, Integer, Map)150%20%224411
createLogContext(String)140%n/a111111
lambda$completeUnrealizedFutures$3(Function, Map.Entry)140%n/a111111
lambda$validAclOperations$13(AclOperation)130%60%441111
describeConfigResult(DescribeConfigsResponseData.DescribeConfigsResult)120%n/a112211
lambda$null$7(DescribeConfigsResponseData.DescribeConfigsSynonym)120%n/a112211
maybeCompleteQuotaExceededException(boolean, Throwable, Map, Map, int)110%40%333311
getScramCredentialDeletion(UserScramCredentialDeletion)110%n/a111111
getSaltedPasword(ScramMechanism, byte[], byte[], int)110%n/a112211
topicNameIsUnrepresentable(String)90%40%331111
handleNotControllerError(AbstractResponse)90%20%223311
handleNotControllerError(Errors)90%n/a113311
lambda$alterUserScramCredentials$22(Map, UserScramCredentialAlteration)90%20%221111
lambda$completeUnrealizedFutures$2(Map.Entry)90%20%221111
completeUnrealizedFutures(Stream, Function)70%n/a112211
lambda$getListOffsetsCalls$18(TopicPartition, String)70%n/a111111
getOrCreateListValue(Map, Object)60%n/a111111
lambda$listOffsets$15(MetadataOperationContext, Map, Map)60%n/a111111
lambda$createPartitions$11(List)60%n/a111111
lambda$describeConfigs$6(Map.Entry)60%n/a111111
static {...}60%n/a111111
completeAllExceptionally(Collection, Throwable)50%n/a112211
completeAllExceptionally(Stream, Throwable)50%n/a112211
createInternal(AdminClientConfig, KafkaAdminClient.TimeoutProcessorFactory)50%n/a111111
numPendingCalls()50%n/a111111
metrics()50%n/a111111
lambda$getListOffsetsCalls$16()50%n/a111111
lambda$deleteConsumerGroups$14(Map.Entry)50%n/a111111
lambda$describeConsumerGroups$12(Map.Entry)50%n/a111111
lambda$completeAllExceptionally$1(Throwable, KafkaFutureImpl)50%n/a111111
lambda$getListOffsetsCalls$17(Node)40%n/a111111
lambda$describeReplicaLogDirs$10(Integer)40%n/a111111
lambda$alterReplicaLogDirs$9(Integer)40%n/a111111
lambda$getOrCreateListValue$0(Object)40%n/a111111
lambda$alterUserScramCredentials$21(UserScramCredentialAlteration)30%n/a111111
lambda$alterUserScramCredentials$19(UserScramCredentialAlteration)30%n/a111111