Source file "org/apache/kafka/clients/admin/KafkaAdminClient.java" was not found during generation of report.
| Element | Missed Instructions | Cov. | Missed Branches | Cov. | Missed | Cxty | Missed | Lines | Missed | Methods |
| Total | 4,604 of 4,604 | 0% | 261 of 261 | 0% | 246 | 246 | 799 | 799 | 113 | 113 |
| createInternal(AdminClientConfig, KafkaAdminClient.TimeoutProcessorFactory, HostResolver) | 0% | 0% | 2 | 2 | 47 | 47 | 1 | 1 | ||
| describeReplicaLogDirs(Collection, DescribeReplicaLogDirsOptions) | 0% | 0% | 7 | 7 | 30 | 30 | 1 | 1 | ||
| alterReplicaLogDirs(Map, AlterReplicaLogDirsOptions) | 0% | 0% | 6 | 6 | 27 | 27 | 1 | 1 | ||
| alterPartitionReassignments(Map, AlterPartitionReassignmentsOptions) | 0% | 0% | 6 | 6 | 26 | 26 | 1 | 1 | ||
| getListOffsetsCalls(MetadataOperationContext, Map, Map) | 0% | 0% | 5 | 5 | 25 | 25 | 1 | 1 | ||
| close(Duration) | 0% | 0% | 7 | 7 | 29 | 29 | 1 | 1 | ||
| createTopics(Collection, CreateTopicsOptions) | 0% | 0% | 5 | 5 | 19 | 19 | 1 | 1 | ||
| createAcls(Collection, CreateAclsOptions) | 0% | 0% | 4 | 4 | 17 | 17 | 1 | 1 | ||
| KafkaAdminClient(AdminClientConfig, String, Time, AdminMetadataManager, Metrics, KafkaClient, KafkaAdminClient.TimeoutProcessorFactory, LogContext) | 0% | 0% | 2 | 2 | 22 | 22 | 1 | 1 | ||
| describeTopics(Collection, DescribeTopicsOptions) | 0% | 0% | 5 | 5 | 16 | 16 | 1 | 1 | ||
| createPartitions(Map, CreatePartitionsOptions) | 0% | 0% | 4 | 4 | 23 | 23 | 1 | 1 | ||
| listPartitionReassignments(Optional, ListPartitionReassignmentsOptions) | 0% | 0% | 6 | 6 | 15 | 15 | 1 | 1 | ||
| handleDeleteTopicsUsingIds(Collection, DeleteTopicsOptions) | 0% | 0% | 5 | 5 | 18 | 18 | 1 | 1 | ||
| handleDeleteTopicsUsingNames(Collection, DeleteTopicsOptions) | 0% | 0% | 5 | 5 | 18 | 18 | 1 | 1 | ||
| describeConfigs(Collection, DescribeConfigsOptions) | 0% | 0% | 4 | 4 | 15 | 15 | 1 | 1 | ||
| lambda$alterUserScramCredentials$23(Map, String, Map, UserScramCredentialAlteration) | 0% | 0% | 7 | 7 | 18 | 18 | 1 | 1 | ||
| alterUserScramCredentials(List, AlterUserScramCredentialsOptions) | 0% | 0% | 2 | 2 | 17 | 17 | 1 | 1 | ||
| alterConfigs(Map, AlterConfigsOptions, Collection, KafkaAdminClient.NodeProvider) | 0% | 0% | 3 | 3 | 12 | 12 | 1 | 1 | ||
| deleteAcls(Collection, DeleteAclsOptions) | 0% | 0% | 3 | 3 | 13 | 13 | 1 | 1 | ||
| logDirDescriptions(DescribeLogDirsResponse) | 0% | 0% | 4 | 4 | 13 | 13 | 1 | 1 | ||
| deleteRecords(Map, DeleteRecordsOptions) | 0% | 0% | 3 | 3 | 12 | 12 | 1 | 1 | ||
| updateFeatures(Map, UpdateFeaturesOptions) | 0% | 0% | 4 | 4 | 13 | 13 | 1 | 1 | ||
| listOffsets(Map, ListOffsetsOptions) | 0% | 0% | 2 | 2 | 12 | 12 | 1 | 1 | ||
| alterConfigs(Map, AlterConfigsOptions) | 0% | 0% | 4 | 4 | 13 | 13 | 1 | 1 | ||
| incrementalAlterConfigs(Map, AlterConfigsOptions) | 0% | 0% | 4 | 4 | 13 | 13 | 1 | 1 | ||
| getMembersFromGroup(String) | 0% | 0% | 3 | 3 | 11 | 11 | 1 | 1 | ||
| createDelegationToken(CreateDelegationTokenOptions) | 0% | 0% | 2 | 2 | 10 | 10 | 1 | 1 | ||
| describeLogDirs(Collection, DescribeLogDirsOptions) | 0% | 0% | 2 | 2 | 9 | 9 | 1 | 1 | ||
| alterClientQuotas(Collection, AlterClientQuotasOptions) | 0% | 0% | 2 | 2 | 7 | 7 | 1 | 1 | ||
| describeAcls(AclBindingFilter, DescribeAclsOptions) | 0% | 0% | 2 | 2 | 8 | 8 | 1 | 1 | ||
| describeCluster(DescribeClusterOptions) | 0% | n/a | 1 | 1 | 7 | 7 | 1 | 1 | ||
| configureDefaultApiTimeoutMs(AdminClientConfig) | 0% | 0% | 3 | 3 | 10 | 10 | 1 | 1 | ||
| incrementalAlterConfigs(Map, AlterConfigsOptions, Collection, KafkaAdminClient.NodeProvider) | 0% | 0% | 2 | 2 | 6 | 6 | 1 | 1 | ||
| removeMembersFromConsumerGroup(String, RemoveMembersFromConsumerGroupOptions) | 0% | 0% | 2 | 2 | 8 | 8 | 1 | 1 | ||
| createInternal(AdminClientConfig, AdminMetadataManager, KafkaClient, Time) | 0% | n/a | 1 | 1 | 8 | 8 | 1 | 1 | ||
| lambda$alterUserScramCredentials$20(Map, UserScramCredentialAlteration) | 0% | 0% | 5 | 5 | 8 | 8 | 1 | 1 | ||
| configSource(DescribeConfigsResponse.ConfigSource) | 0% | 0% | 7 | 7 | 15 | 15 | 1 | 1 | ||
| listConsumerGroups(ListConsumerGroupsOptions) | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | ||
| deleteTopics(TopicCollection, DeleteTopicsOptions) | 0% | 0% | 3 | 3 | 5 | 5 | 1 | 1 | ||
| describeUserScramCredentials(List, DescribeUserScramCredentialsOptions) | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | ||
| unregisterBroker(int, UnregisterBrokerOptions) | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | ||
| newCall(AdminApiDriver, AdminApiDriver.RequestSpec) | 0% | 0% | 2 | 2 | 3 | 3 | 1 | 1 | ||
| renewDelegationToken(byte[], RenewDelegationTokenOptions) | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | ||
| expireDelegationToken(byte[], ExpireDelegationTokenOptions) | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | ||
| electLeaders(ElectionType, Set, ElectLeadersOptions) | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | ||
| describeFeatures(DescribeFeaturesOptions) | 0% | n/a | 1 | 1 | 6 | 6 | 1 | 1 | ||
| listTopics(ListTopicsOptions) | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | ||
| describeDelegationToken(DescribeDelegationTokenOptions) | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | ||
| describeClientQuotas(ClientQuotaFilter, DescribeClientQuotasOptions) | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | ||
| getScramCredentialUpsertion(UserScramCredentialUpsertion) | 0% | n/a | 1 | 1 | 6 | 6 | 1 | 1 | ||
| describeConsumerGroups(Collection, DescribeConsumerGroupsOptions) | 0% | n/a | 1 | 1 | 6 | 6 | 1 | 1 | ||
| lambda$describeConfigResult$8(DescribeConfigsResponseData.DescribeConfigsResourceResult) | 0% | n/a | 1 | 1 | 10 | 10 | 1 | 1 | ||
| deleteConsumerGroups(Collection, DeleteConsumerGroupsOptions) | 0% | n/a | 1 | 1 | 6 | 6 | 1 | 1 | ||
| listConsumerGroupOffsets(String, ListConsumerGroupOffsetsOptions) | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | ||
| deleteConsumerGroupOffsets(String, Set, DeleteConsumerGroupOffsetsOptions) | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | ||
| prettyPrintException(Throwable) | 0% | 0% | 3 | 3 | 5 | 5 | 1 | 1 | ||
| alterConsumerGroupOffsets(String, Map, AlterConsumerGroupOffsetsOptions) | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | ||
| invokeDriver(AdminApiHandler, AdminApiFuture, Integer) | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | ||
| abortTransaction(AbortTransactionSpec, AbortTransactionOptions) | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | ||
| describeProducers(Collection, DescribeProducersOptions) | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | ||
| describeTransactions(Collection, DescribeTransactionsOptions) | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | ||
| listTransactions(ListTransactionsOptions) | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | ||
| maybeSendRequests(AdminApiDriver, long) | 0% | 0% | 2 | 2 | 4 | 4 | 1 | 1 | ||
| calcTimeoutMsRemainingAsInt(long, long) | 0% | 0% | 3 | 3 | 6 | 6 | 1 | 1 | ||
| rescheduleMetadataTask(MetadataOperationContext, Supplier) | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | ||
| generateClientId(AdminClientConfig) | 0% | 0% | 2 | 2 | 4 | 4 | 1 | 1 | ||
| getOffsetFromOffsetSpec(OffsetSpec) | 0% | 0% | 4 | 4 | 7 | 7 | 1 | 1 | ||
| getCreateTopicsCall(CreateTopicsOptions, Map, CreateTopicsRequestData.CreatableTopicCollection, Map, long, long) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| getDeleteTopicsCall(DeleteTopicsOptions, Map, List, Map, long, long) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| getDeleteTopicsWithIdsCall(DeleteTopicsOptions, Map, List, Map, long, long) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| getCreatePartitionsCall(CreatePartitionsOptions, Map, CreatePartitionsRequestData.CreatePartitionsTopicCollection, Map, long, long) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$maybeCompleteQuotaExceededException$4(Map, int, Object, ThrottlingQuotaExceededException) | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | ||
| nodeFor(ConfigResource) | 0% | 0% | 4 | 4 | 4 | 4 | 1 | 1 | ||
| calcDeadlineMs(long, Integer) | 0% | 0% | 2 | 2 | 3 | 3 | 1 | 1 | ||
| validAclOperations(int) | 0% | 0% | 2 | 2 | 7 | 7 | 1 | 1 | ||
| getMetadataCall(MetadataOperationContext, Supplier) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| getSubLevelError(Map, Object, String) | 0% | 0% | 2 | 2 | 3 | 3 | 1 | 1 | ||
| lambda$describeConfigs$5(ConfigResource, Integer, Map) | 0% | 0% | 2 | 2 | 4 | 4 | 1 | 1 | ||
| createLogContext(String) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$completeUnrealizedFutures$3(Function, Map.Entry) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$validAclOperations$13(AclOperation) | 0% | 0% | 4 | 4 | 1 | 1 | 1 | 1 | ||
| describeConfigResult(DescribeConfigsResponseData.DescribeConfigsResult) | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| lambda$null$7(DescribeConfigsResponseData.DescribeConfigsSynonym) | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| maybeCompleteQuotaExceededException(boolean, Throwable, Map, Map, int) | 0% | 0% | 3 | 3 | 3 | 3 | 1 | 1 | ||
| getScramCredentialDeletion(UserScramCredentialDeletion) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| getSaltedPasword(ScramMechanism, byte[], byte[], int) | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| topicNameIsUnrepresentable(String) | 0% | 0% | 3 | 3 | 1 | 1 | 1 | 1 | ||
| handleNotControllerError(AbstractResponse) | 0% | 0% | 2 | 2 | 3 | 3 | 1 | 1 | ||
| handleNotControllerError(Errors) | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | ||
| lambda$alterUserScramCredentials$22(Map, UserScramCredentialAlteration) | 0% | 0% | 2 | 2 | 1 | 1 | 1 | 1 | ||
| lambda$completeUnrealizedFutures$2(Map.Entry) | 0% | 0% | 2 | 2 | 1 | 1 | 1 | 1 | ||
| completeUnrealizedFutures(Stream, Function) | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| lambda$getListOffsetsCalls$18(TopicPartition, String) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| getOrCreateListValue(Map, Object) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$listOffsets$15(MetadataOperationContext, Map, Map) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$createPartitions$11(List) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$describeConfigs$6(Map.Entry) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| static {...} | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| completeAllExceptionally(Collection, Throwable) | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| completeAllExceptionally(Stream, Throwable) | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | ||
| createInternal(AdminClientConfig, KafkaAdminClient.TimeoutProcessorFactory) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| numPendingCalls() | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| metrics() | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$getListOffsetsCalls$16() | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$deleteConsumerGroups$14(Map.Entry) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$describeConsumerGroups$12(Map.Entry) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$completeAllExceptionally$1(Throwable, KafkaFutureImpl) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$getListOffsetsCalls$17(Node) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$describeReplicaLogDirs$10(Integer) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$alterReplicaLogDirs$9(Integer) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$getOrCreateListValue$0(Object) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$alterUserScramCredentials$21(UserScramCredentialAlteration) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | ||
| lambda$alterUserScramCredentials$19(UserScramCredentialAlteration) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 |