|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/AdminClientWithPoliciesIntegrationTest.java
|
scanned
|
file
|
11.0 KB
|
AdminClientWithPoliciesIntegrationTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/AdminFenceProducersTest.java
|
scanned
|
file
|
6.4 KB
|
AdminFenceProducersTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/ClientTelemetryTest.java
|
scanned
|
file
|
9.0 KB
|
ClientTelemetryTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/ConcurrentListOffsetsRequestTest.java
|
scanned
|
file
|
9.2 KB
|
ConcurrentListOffsetsRequestTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/DeleteTopicTest.java
|
scanned
|
file
|
18.7 KB
|
DeleteTopicTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/DescribeAuthorizedOperationsTest.java
|
scanned
|
file
|
13.9 KB
|
DescribeAuthorizedOperationsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/DescribeFeaturesTest.java
|
scanned
|
file
|
7.3 KB
|
DescribeFeaturesTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/DescribeProducersWithBrokerIdTest.java
|
scanned
|
file
|
6.0 KB
|
DescribeProducersWithBrokerIdTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/ListOffsetsIntegrationTest.java
|
scanned
|
file
|
14.0 KB
|
ListOffsetsIntegrationTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/RackAwareAutoTopicCreationTest.java
|
scanned
|
file
|
7.3 KB
|
RackAwareAutoTopicCreationTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/admin/StaticBrokerConfigTest.java
|
scanned
|
file
|
10.8 KB
|
StaticBrokerConfigTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/ClientRebootstrapTest.java
|
scanned
|
file
|
13.7 KB
|
ClientRebootstrapTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/ClientsTestUtils.java
|
scanned
|
file
|
20.6 KB
|
ClientsTestUtils.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ConsumerAssignmentPoller.java
|
scanned
|
file
|
5.0 KB
|
ConsumerAssignmentPoller.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ConsumerBounceTest.java
|
scanned
|
file
|
35.9 KB
|
ConsumerBounceTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ConsumerIntegrationTest.java
|
scanned
|
file
|
20.3 KB
|
ConsumerIntegrationTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ConsumerTopicCreationTest.java
|
scanned
|
file
|
5.4 KB
|
ConsumerTopicCreationTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ConsumerWithLegacyMessageFormatIntegrationTest.java
|
scanned
|
file
|
9.6 KB
|
ConsumerWithLegacyMessageFormatIntegrationTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/PlaintextConsumerAssignTest.java
|
scanned
|
file
|
14.3 KB
|
PlaintextConsumerAssignTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/PlaintextConsumerCallbackTest.java
|
scanned
|
file
|
16.4 KB
|
PlaintextConsumerCallbackTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/PlaintextConsumerCommitTest.java
|
scanned
|
file
|
27.5 KB
|
PlaintextConsumerCommitTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/PlaintextConsumerFetchTest.java
|
scanned
|
file
|
21.9 KB
|
PlaintextConsumerFetchTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/PlaintextConsumerPollTest.java
|
scanned
|
file
|
30.8 KB
|
PlaintextConsumerPollTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/PlaintextConsumerSubscriptionTest.java
|
scanned
|
file
|
28.5 KB
|
PlaintextConsumerSubscriptionTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/PlaintextConsumerTest.java
|
scanned
|
file
|
78.9 KB
|
PlaintextConsumerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/RackAwareAssignor.java
|
scanned
|
file
|
4.8 KB
|
RackAwareAssignor.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/SaslPlainPlaintextConsumerTest.java
|
scanned
|
file
|
7.3 KB
|
SaslPlainPlaintextConsumerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ShareConsumerRackAwareTest.java
|
scanned
|
file
|
9.7 KB
|
ShareConsumerRackAwareTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ShareConsumerTest.java
|
scanned
|
file
|
221.8 KB
|
ShareConsumerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/CreateTopicsRequestWithPolicyTest.java
|
scanned
|
file
|
10.3 KB
|
CreateTopicsRequestWithPolicyTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/MetadataVersionIntegrationTest.java
|
scanned
|
file
|
4.5 KB
|
MetadataVersionIntegrationTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/MetricsDuringTopicCreationDeletionTest.java
|
scanned
|
file
|
6.7 KB
|
MetricsDuringTopicCreationDeletionTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/producer/ProducerCompressionTest.java
|
scanned
|
file
|
8.7 KB
|
ProducerCompressionTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/producer/ProducerFailureHandlingTest.java
|
scanned
|
file
|
14.6 KB
|
ProducerFailureHandlingTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/producer/ProducerIdExpirationTest.java
|
scanned
|
file
|
14.5 KB
|
ProducerIdExpirationTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/producer/ProducerSendWhileDeletionTest.java
|
scanned
|
file
|
15.1 KB
|
ProducerSendWhileDeletionTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/security/GroupAuthorizerIntegrationTest.java
|
scanned
|
file
|
20.8 KB
|
GroupAuthorizerIntegrationTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/TransactionsExpirationTest.java
|
scanned
|
file
|
17.1 KB
|
TransactionsExpirationTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/TransactionsWithMaxInFlightOneTest.java
|
scanned
|
file
|
7.0 KB
|
TransactionsWithMaxInFlightOneTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/clients-integration-tests/src/test/java/org/apache/kafka/server/quota/CustomQuotaCallbackTest.java
|
scanned
|
file
|
7.3 KB
|
CustomQuotaCallbackTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AbortTransactionOptions.java
|
scanned
|
file
|
1.1 KB
|
AbortTransactionOptions.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AbortTransactionResult.java
|
scanned
|
file
|
1.7 KB
|
AbortTransactionResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AbortTransactionSpec.java
|
scanned
|
file
|
2.6 KB
|
AbortTransactionSpec.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AbstractOptions.java
|
scanned
|
file
|
1.6 KB
|
AbstractOptions.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AddRaftVoterOptions.java
|
scanned
|
file
|
1.7 KB
|
AddRaftVoterOptions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AddRaftVoterResult.java
|
scanned
|
file
|
1.5 KB
|
AddRaftVoterResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java
|
scanned
|
file
|
18.3 KB
|
AdminClientConfig.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AdminClient.java
|
scanned
|
file
|
1.7 KB
|
AdminClient.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/Admin.java
|
scanned
|
file
|
101.0 KB
|
Admin.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AlterClientQuotasOptions.java
|
scanned
|
file
|
1.5 KB
|
AlterClientQuotasOptions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AlterClientQuotasResult.java
|
scanned
|
file
|
1.9 KB
|
AlterClientQuotasResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigOp.java
|
scanned
|
file
|
4.1 KB
|
AlterConfigOp.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigsOptions.java
|
scanned
|
file
|
1.8 KB
|
AlterConfigsOptions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigsResult.java
|
scanned
|
file
|
1.7 KB
|
AlterConfigsResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AlterConsumerGroupOffsetsOptions.java
|
scanned
|
file
|
1.1 KB
|
AlterConsumerGroupOffsetsOptions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AlterConsumerGroupOffsetsResult.java
|
scanned
|
file
|
3.2 KB
|
AlterConsumerGroupOffsetsResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AlterPartitionReassignmentsOptions.java
|
scanned
|
file
|
1.9 KB
|
AlterPartitionReassignmentsOptions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AlterPartitionReassignmentsResult.java
|
scanned
|
file
|
2.1 KB
|
AlterPartitionReassignmentsResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AlterReplicaLogDirsOptions.java
|
scanned
|
file
|
1.0 KB
|
AlterReplicaLogDirsOptions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AlterReplicaLogDirsResult.java
|
scanned
|
file
|
3.7 KB
|
AlterReplicaLogDirsResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AlterShareGroupOffsetsOptions.java
|
scanned
|
file
|
1.0 KB
|
AlterShareGroupOffsetsOptions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AlterShareGroupOffsetsResult.java
|
scanned
|
file
|
3.3 KB
|
AlterShareGroupOffsetsResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AlterStreamsGroupOffsetsOptions.java
|
scanned
|
file
|
1.2 KB
|
AlterStreamsGroupOffsetsOptions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AlterStreamsGroupOffsetsResult.java
|
scanned
|
file
|
1.8 KB
|
AlterStreamsGroupOffsetsResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AlterUserScramCredentialsOptions.java
|
scanned
|
file
|
1.1 KB
|
AlterUserScramCredentialsOptions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/AlterUserScramCredentialsResult.java
|
scanned
|
file
|
2.0 KB
|
AlterUserScramCredentialsResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/ClassicGroupDescription.java
|
scanned
|
file
|
5.3 KB
|
ClassicGroupDescription.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/ClientMetricsResourceListing.java
|
scanned
|
file
|
1.6 KB
|
ClientMetricsResourceListing.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java
|
scanned
|
file
|
9.5 KB
|
ConfigEntry.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/Config.java
|
scanned
|
file
|
2.2 KB
|
Config.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupDescription.java
|
scanned
|
file
|
9.8 KB
|
ConsumerGroupDescription.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupListing.java
|
scanned
|
file
|
6.1 KB
|
ConsumerGroupListing.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/CreateAclsOptions.java
|
scanned
|
file
|
1.3 KB
|
CreateAclsOptions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/CreateAclsResult.java
|
scanned
|
file
|
1.7 KB
|
CreateAclsResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/CreateDelegationTokenOptions.java
|
scanned
|
file
|
2.3 KB
|
CreateDelegationTokenOptions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/CreateDelegationTokenResult.java
|
scanned
|
file
|
1.5 KB
|
CreateDelegationTokenResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/CreatePartitionsOptions.java
|
scanned
|
file
|
2.0 KB
|
CreatePartitionsOptions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/CreatePartitionsResult.java
|
scanned
|
file
|
1.6 KB
|
CreatePartitionsResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/CreateTopicsOptions.java
|
scanned
|
file
|
2.3 KB
|
CreateTopicsOptions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/CreateTopicsResult.java
|
scanned
|
file
|
6.0 KB
|
CreateTopicsResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/DeleteAclsOptions.java
|
scanned
|
file
|
1.3 KB
|
DeleteAclsOptions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/DeleteAclsResult.java
|
scanned
|
file
|
4.1 KB
|
DeleteAclsResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupOffsetsOptions.java
|
scanned
|
file
|
1.0 KB
|
DeleteConsumerGroupOffsetsOptions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupOffsetsResult.java
|
scanned
|
file
|
3.6 KB
|
DeleteConsumerGroupOffsetsResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupsOptions.java
|
scanned
|
file
|
1.0 KB
|
DeleteConsumerGroupsOptions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/DeleteConsumerGroupsResult.java
|
scanned
|
file
|
1.8 KB
|
DeleteConsumerGroupsResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/DeletedRecords.java
|
scanned
|
file
|
1.4 KB
|
DeletedRecords.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/DeleteRecordsOptions.java
|
scanned
|
file
|
1.0 KB
|
DeleteRecordsOptions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/DeleteRecordsResult.java
|
scanned
|
file
|
1.7 KB
|
DeleteRecordsResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/DeleteShareGroupOffsetsOptions.java
|
scanned
|
file
|
1.0 KB
|
DeleteShareGroupOffsetsOptions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/DeleteShareGroupOffsetsResult.java
|
scanned
|
file
|
3.6 KB
|
DeleteShareGroupOffsetsResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/DeleteShareGroupsOptions.java
|
scanned
|
file
|
1.0 KB
|
DeleteShareGroupsOptions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/DeleteShareGroupsResult.java
|
scanned
|
file
|
1.8 KB
|
DeleteShareGroupsResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/DeleteStreamsGroupOffsetsOptions.java
|
scanned
|
file
|
1.2 KB
|
DeleteStreamsGroupOffsetsOptions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/DeleteStreamsGroupOffsetsResult.java
|
scanned
|
file
|
2.1 KB
|
DeleteStreamsGroupOffsetsResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/DeleteStreamsGroupsOptions.java
|
scanned
|
file
|
1.2 KB
|
DeleteStreamsGroupsOptions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/DeleteStreamsGroupsResult.java
|
scanned
|
file
|
1.9 KB
|
DeleteStreamsGroupsResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/DeleteTopicsOptions.java
|
scanned
|
file
|
1.8 KB
|
DeleteTopicsOptions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/DeleteTopicsResult.java
|
scanned
|
file
|
3.2 KB
|
DeleteTopicsResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/admin/DescribeAclsOptions.java
|
scanned
|
file
|
1.4 KB
|
DescribeAclsOptions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|