|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/CloseableIterator.java
|
scanned
|
file
|
1.7 KB
|
CloseableIterator.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/CollectionUtils.java
|
scanned
|
file
|
3.4 KB
|
CollectionUtils.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/ConfigUtils.java
|
scanned
|
file
|
3.3 KB
|
ConfigUtils.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/CopyOnWriteMap.java
|
scanned
|
file
|
4.0 KB
|
CopyOnWriteMap.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/Crc32C.java
|
scanned
|
file
|
2.2 KB
|
Crc32C.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/Exit.java
|
scanned
|
file
|
4.3 KB
|
Exit.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/ExponentialBackoff.java
|
scanned
|
file
|
3.1 KB
|
ExponentialBackoff.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/ExponentialBackoffManager.java
|
scanned
|
file
|
1.7 KB
|
ExponentialBackoffManager.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/FixedOrderMap.java
|
scanned
|
file
|
2.0 KB
|
FixedOrderMap.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/ImplicitLinkedHashCollection.java
|
scanned
|
file
|
23.0 KB
|
ImplicitLinkedHashCollection.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/ImplicitLinkedHashMultiCollection.java
|
scanned
|
file
|
5.1 KB
|
ImplicitLinkedHashMultiCollection.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/Java.java
|
scanned
|
file
|
1.1 KB
|
Java.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/KafkaThread.java
|
scanned
|
file
|
1.9 KB
|
KafkaThread.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/LogContext.java
|
scanned
|
file
|
24.6 KB
|
LogContext.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/LoggingSignalHandler.java
|
scanned
|
file
|
4.7 KB
|
LoggingSignalHandler.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/MappedIterator.java
|
scanned
|
file
|
1.5 KB
|
MappedIterator.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/OperatingSystem.java
|
scanned
|
file
|
1.2 KB
|
OperatingSystem.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/package-info.java
|
scanned
|
file
|
1.0 KB
|
package-info.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/PrimitiveRef.java
|
scanned
|
file
|
1.6 KB
|
PrimitiveRef.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/ProducerIdAndEpoch.java
|
scanned
|
file
|
1.9 KB
|
ProducerIdAndEpoch.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/Sanitizer.java
|
scanned
|
file
|
3.0 KB
|
Sanitizer.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/Scheduler.java
|
scanned
|
file
|
1.9 KB
|
Scheduler.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/SecurityUtils.java
|
scanned
|
file
|
7.3 KB
|
SecurityUtils.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/Shell.java
|
scanned
|
file
|
9.6 KB
|
Shell.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/SystemScheduler.java
|
scanned
|
file
|
1.5 KB
|
SystemScheduler.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/SystemTime.java
|
scanned
|
file
|
2.0 KB
|
SystemTime.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/ThreadUtils.java
|
scanned
|
file
|
5.0 KB
|
ThreadUtils.java
|
.java
|
Java
|
text/html
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/Time.java
|
scanned
|
file
|
4.4 KB
|
Time.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/Timer.java
|
scanned
|
file
|
8.1 KB
|
Timer.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/utils/Utils.java
|
scanned
|
file
|
67.7 KB
|
Utils.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/Uuid.java
|
scanned
|
file
|
6.7 KB
|
Uuid.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/server/authorizer/AclCreateResult.java
|
scanned
|
file
|
1.4 KB
|
AclCreateResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/server/authorizer/AclDeleteResult.java
|
scanned
|
file
|
3.2 KB
|
AclDeleteResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/server/authorizer/Action.java
|
scanned
|
file
|
4.8 KB
|
Action.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/server/authorizer/AuthorizableRequestContext.java
|
scanned
|
file
|
2.1 KB
|
AuthorizableRequestContext.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/server/authorizer/AuthorizationResult.java
|
scanned
|
file
|
905 bytes
|
AuthorizationResult.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/server/authorizer/Authorizer.java
|
scanned
|
file
|
14.8 KB
|
Authorizer.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/server/authorizer/AuthorizerServerInfo.java
|
scanned
|
file
|
1.8 KB
|
AuthorizerServerInfo.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/server/authorizer/package-info.java
|
scanned
|
file
|
930 bytes
|
package-info.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/server/policy/AlterConfigPolicy.java
|
scanned
|
file
|
3.9 KB
|
AlterConfigPolicy.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/server/policy/CreateTopicPolicy.java
|
scanned
|
file
|
6.4 KB
|
CreateTopicPolicy.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/server/policy/package-info.java
|
scanned
|
file
|
926 bytes
|
package-info.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/server/quota/ClientQuotaCallback.java
|
scanned
|
file
|
5.7 KB
|
ClientQuotaCallback.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/server/quota/ClientQuotaEntity.java
|
scanned
|
file
|
2.1 KB
|
ClientQuotaEntity.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/server/quota/ClientQuotaType.java
|
scanned
|
file
|
1014 bytes
|
ClientQuotaType.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/server/quota/package-info.java
|
scanned
|
file
|
926 bytes
|
package-info.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/server/telemetry/ClientTelemetryContext.java
|
scanned
|
file
|
1.9 KB
|
ClientTelemetryContext.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/server/telemetry/ClientTelemetryExporter.java
|
scanned
|
file
|
1.8 KB
|
ClientTelemetryExporter.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/server/telemetry/ClientTelemetryExporterProvider.java
|
scanned
|
file
|
1.4 KB
|
ClientTelemetryExporterProvider.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/server/telemetry/ClientTelemetry.java
|
scanned
|
file
|
1.7 KB
|
ClientTelemetry.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/server/telemetry/ClientTelemetryPayload.java
|
scanned
|
file
|
1.8 KB
|
ClientTelemetryPayload.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/server/telemetry/ClientTelemetryReceiver.java
|
scanned
|
file
|
2.0 KB
|
ClientTelemetryReceiver.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/server/telemetry/package-info.java
|
scanned
|
file
|
921 bytes
|
package-info.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/AddressChangeHostResolver.java
|
scanned
|
file
|
1.6 KB
|
AddressChangeHostResolver.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/AdminClientConfigTest.java
|
scanned
|
file
|
2.0 KB
|
AdminClientConfigTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/AdminClientTestUtils.java
|
scanned
|
file
|
10.2 KB
|
AdminClientTestUtils.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/AdminClientUnitTestEnv.java
|
scanned
|
file
|
5.2 KB
|
AdminClientUnitTestEnv.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/ConfigTest.java
|
scanned
|
file
|
3.8 KB
|
ConfigTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/ConsumerGroupDescriptionTest.java
|
scanned
|
file
|
1.6 KB
|
ConsumerGroupDescriptionTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/ConsumerGroupListingTest.java
|
scanned
|
file
|
1.5 KB
|
ConsumerGroupListingTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/DeleteConsumerGroupOffsetsResultTest.java
|
scanned
|
file
|
5.3 KB
|
DeleteConsumerGroupOffsetsResultTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/DeleteTopicsResultTest.java
|
scanned
|
file
|
2.6 KB
|
DeleteTopicsResultTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/DescribeTopicsResultTest.java
|
scanned
|
file
|
1.7 KB
|
DescribeTopicsResultTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/DescribeUserScramCredentialsResultTest.java
|
scanned
|
file
|
6.3 KB
|
DescribeUserScramCredentialsResultTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/EndpointTypeTest.java
|
scanned
|
file
|
1.5 KB
|
EndpointTypeTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/FakeForwardingAdmin.java
|
scanned
|
file
|
1017 bytes
|
FakeForwardingAdmin.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/GroupListingTest.java
|
scanned
|
file
|
1.9 KB
|
GroupListingTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/internals/AbortTransactionHandlerTest.java
|
scanned
|
file
|
11.2 KB
|
AbortTransactionHandlerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/internals/AdminApiDriverTest.java
|
scanned
|
file
|
32.8 KB
|
AdminApiDriverTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/internals/AdminBootstrapAddressesTest.java
|
scanned
|
file
|
3.4 KB
|
AdminBootstrapAddressesTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/internals/AdminFetchMetricsManagerTest.java
|
scanned
|
file
|
7.4 KB
|
AdminFetchMetricsManagerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/internals/AdminMetadataManagerTest.java
|
scanned
|
file
|
7.4 KB
|
AdminMetadataManagerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/internals/AllBrokersStrategyIntegrationTest.java
|
scanned
|
file
|
11.3 KB
|
AllBrokersStrategyIntegrationTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/internals/AllBrokersStrategyTest.java
|
scanned
|
file
|
5.4 KB
|
AllBrokersStrategyTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/internals/AlterConsumerGroupOffsetsHandlerTest.java
|
scanned
|
file
|
8.3 KB
|
AlterConsumerGroupOffsetsHandlerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/internals/CoordinatorStrategyTest.java
|
scanned
|
file
|
12.8 KB
|
CoordinatorStrategyTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/internals/DeleteConsumerGroupOffsetsHandlerTest.java
|
scanned
|
file
|
9.8 KB
|
DeleteConsumerGroupOffsetsHandlerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/internals/DeleteConsumerGroupsHandlerTest.java
|
scanned
|
file
|
1.1 KB
|
DeleteConsumerGroupsHandlerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/internals/DeleteGroupsHandlerTest.java
|
scanned
|
file
|
5.5 KB
|
DeleteGroupsHandlerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/internals/DeleteRecordsHandlerTest.java
|
scanned
|
file
|
15.5 KB
|
DeleteRecordsHandlerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/internals/DeleteShareGroupsHandlerTest.java
|
scanned
|
file
|
1.1 KB
|
DeleteShareGroupsHandlerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/internals/DescribeConsumerGroupsHandlerTest.java
|
scanned
|
file
|
20.4 KB
|
DescribeConsumerGroupsHandlerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/internals/DescribeProducersHandlerTest.java
|
scanned
|
file
|
14.0 KB
|
DescribeProducersHandlerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/internals/DescribeTransactionsHandlerTest.java
|
scanned
|
file
|
10.0 KB
|
DescribeTransactionsHandlerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/internals/FenceProducersHandlerTest.java
|
scanned
|
file
|
7.1 KB
|
FenceProducersHandlerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/internals/ListConsumerGroupOffsetsHandlerTest.java
|
scanned
|
file
|
28.1 KB
|
ListConsumerGroupOffsetsHandlerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/internals/ListOffsetsHandlerTest.java
|
scanned
|
file
|
16.6 KB
|
ListOffsetsHandlerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/internals/ListTransactionsHandlerTest.java
|
scanned
|
file
|
12.2 KB
|
ListTransactionsHandlerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/internals/PartitionLeaderStrategyIntegrationTest.java
|
scanned
|
file
|
24.4 KB
|
PartitionLeaderStrategyIntegrationTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/internals/PartitionLeaderStrategyTest.java
|
scanned
|
file
|
12.4 KB
|
PartitionLeaderStrategyTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/internals/RemoveMembersFromConsumerGroupHandlerTest.java
|
scanned
|
file
|
7.9 KB
|
RemoveMembersFromConsumerGroupHandlerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
|
scanned
|
file
|
612.8 KB
|
KafkaAdminClientTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/ListConsumerGroupsOptionsTest.java
|
scanned
|
file
|
1.4 KB
|
ListConsumerGroupsOptionsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/ListGroupsOptionsTest.java
|
scanned
|
file
|
5.2 KB
|
ListGroupsOptionsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/ListTransactionsResultTest.java
|
scanned
|
file
|
5.0 KB
|
ListTransactionsResultTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/MemberDescriptionTest.java
|
scanned
|
file
|
10.2 KB
|
MemberDescriptionTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java
|
scanned
|
file
|
71.5 KB
|
MockAdminClient.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/NewTopicTest.java
|
scanned
|
file
|
8.5 KB
|
NewTopicTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupOptionsTest.java
|
scanned
|
file
|
1.6 KB
|
RemoveMembersFromConsumerGroupOptionsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupResultTest.java
|
scanned
|
file
|
5.4 KB
|
RemoveMembersFromConsumerGroupResultTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|