|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/StreamsGroupMemberTest.java
|
scanned
|
file
|
23.1 KB
|
StreamsGroupMemberTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/StreamsGroupTest.java
|
scanned
|
file
|
55.5 KB
|
StreamsGroupTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/StreamsTopologyTest.java
|
scanned
|
file
|
15.5 KB
|
StreamsTopologyTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/TargetAssignmentBuilderTest.java
|
scanned
|
file
|
33.0 KB
|
TargetAssignmentBuilderTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/TaskAssignmentTestUtil.java
|
scanned
|
file
|
5.1 KB
|
TaskAssignmentTestUtil.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/TasksTupleTest.java
|
scanned
|
file
|
7.3 KB
|
TasksTupleTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/TasksTupleWithEpochsTest.java
|
scanned
|
file
|
10.2 KB
|
TasksTupleWithEpochsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/TopicMetadataTest.java
|
scanned
|
file
|
2.8 KB
|
TopicMetadataTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics
|
scanned
|
directory
|
|
topics
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/ChangelogTopicsTest.java
|
scanned
|
file
|
8.1 KB
|
ChangelogTopicsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/ConfiguredInternalTopicTest.java
|
scanned
|
file
|
3.0 KB
|
ConfiguredInternalTopicTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/ConfiguredSubtopologyTest.java
|
scanned
|
file
|
4.3 KB
|
ConfiguredSubtopologyTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/ConfiguredTopologyTest.java
|
scanned
|
file
|
5.0 KB
|
ConfiguredTopologyTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/CopartitionedTopicsEnforcerTest.java
|
scanned
|
file
|
9.6 KB
|
CopartitionedTopicsEnforcerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/EndpointToPartitionsManagerTest.java
|
scanned
|
file
|
9.6 KB
|
EndpointToPartitionsManagerTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/InternalTopicManagerTest.java
|
scanned
|
file
|
8.5 KB
|
InternalTopicManagerTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/RepartitionTopicsTest.java
|
scanned
|
file
|
9.4 KB
|
RepartitionTopicsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/TopicConfigurationExceptionTest.java
|
scanned
|
file
|
1.9 KB
|
TopicConfigurationExceptionTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/TopologyMetadataTest.java
|
scanned
|
file
|
4.5 KB
|
TopologyMetadataTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/UtilsTest.java
|
scanned
|
file
|
9.5 KB
|
UtilsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/resources
|
scanned
|
directory
|
|
resources
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/resources/log4j2.yaml
|
scanned
|
file
|
923 bytes
|
log4j2.yaml
|
.yaml
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/HEADER
|
scanned
|
file
|
754 bytes
|
HEADER
|
|
verilog
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks
|
scanned
|
directory
|
|
jmh-benchmarks
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/jmh.sh
|
scanned
|
file
|
1.4 KB
|
jmh.sh
|
.sh
|
Bash
|
text/x-shellscript
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/README.md
|
scanned
|
file
|
5.9 KB
|
README.md
|
.md
|
|
text/plain
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src
|
scanned
|
directory
|
|
src
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main
|
scanned
|
directory
|
|
main
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java
|
scanned
|
directory
|
|
java
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org
|
scanned
|
directory
|
|
org
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache
|
scanned
|
directory
|
|
apache
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka
|
scanned
|
directory
|
|
kafka
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh
|
scanned
|
directory
|
|
jmh
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/acl
|
scanned
|
directory
|
|
acl
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/acl/AuthorizerBenchmark.java
|
scanned
|
file
|
9.9 KB
|
AuthorizerBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/acl/StandardAuthorizerUpdateBenchmark.java
|
scanned
|
file
|
4.9 KB
|
StandardAuthorizerUpdateBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/assignor
|
scanned
|
directory
|
|
assignor
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/assignor/AssignorBenchmarkUtils.java
|
scanned
|
file
|
13.8 KB
|
AssignorBenchmarkUtils.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/assignor/ClientSideAssignorBenchmark.java
|
scanned
|
file
|
10.7 KB
|
ClientSideAssignorBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/assignor/CurrentAssignmentBuilderBenchmark.java
|
scanned
|
file
|
6.2 KB
|
CurrentAssignmentBuilderBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/assignor/ServerSideAssignorBenchmark.java
|
scanned
|
file
|
8.7 KB
|
ServerSideAssignorBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/assignor/ShareGroupAssignorBenchmark.java
|
scanned
|
file
|
8.1 KB
|
ShareGroupAssignorBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/assignor/StreamsAssignorBenchmarkUtils.java
|
scanned
|
file
|
5.2 KB
|
StreamsAssignorBenchmarkUtils.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/assignor/StreamsStickyAssignorBenchmark.java
|
scanned
|
file
|
6.5 KB
|
StreamsStickyAssignorBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/assignor/TargetAssignmentBuilderBenchmark.java
|
scanned
|
file
|
7.2 KB
|
TargetAssignmentBuilderBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/cache
|
scanned
|
directory
|
|
cache
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/cache/LRUCacheBenchmark.java
|
scanned
|
file
|
2.9 KB
|
LRUCacheBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/clients
|
scanned
|
directory
|
|
clients
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/clients/Murmur2Benchmark.java
|
scanned
|
file
|
3.3 KB
|
Murmur2Benchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common
|
scanned
|
directory
|
|
common
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common/FetchRequestBenchmark.java
|
scanned
|
file
|
5.2 KB
|
FetchRequestBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common/FetchResponseBenchmark.java
|
scanned
|
file
|
5.2 KB
|
FetchResponseBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common/ImplicitLinkedHashCollectionBenchmark.java
|
scanned
|
file
|
3.6 KB
|
ImplicitLinkedHashCollectionBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common/ListOffsetRequestBenchmark.java
|
scanned
|
file
|
3.0 KB
|
ListOffsetRequestBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common/MetadataResponseBenchmark.java
|
scanned
|
file
|
3.2 KB
|
MetadataResponseBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common/ProduceRequestBenchmark.java
|
scanned
|
file
|
2.3 KB
|
ProduceRequestBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common/TopicBenchmark.java
|
scanned
|
file
|
2.0 KB
|
TopicBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/connect
|
scanned
|
directory
|
|
connect
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/connect/JsonConverterBenchmark.java
|
scanned
|
file
|
18.6 KB
|
JsonConverterBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/connect/ReplaceFieldBenchmark.java
|
scanned
|
file
|
3.3 KB
|
ReplaceFieldBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/connect/ValuesBenchmark.java
|
scanned
|
file
|
12.3 KB
|
ValuesBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/consumer
|
scanned
|
directory
|
|
consumer
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/consumer/SubscriptionStateBenchmark.java
|
scanned
|
file
|
3.5 KB
|
SubscriptionStateBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/coordinator
|
scanned
|
directory
|
|
coordinator
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/coordinator/GroupCoordinatorShardLoadingBenchmark.java
|
scanned
|
file
|
14.0 KB
|
GroupCoordinatorShardLoadingBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/coordinator/MockLog.java
|
scanned
|
file
|
2.7 KB
|
MockLog.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/coordinator/RegexResolutionBenchmark.java
|
scanned
|
file
|
4.1 KB
|
RegexResolutionBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/coordinator/TransactionalOffsetFetchBenchmark.java
|
scanned
|
file
|
5.4 KB
|
TransactionalOffsetFetchBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/core
|
scanned
|
directory
|
|
core
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/core/TestPurgatoryPerformance.java
|
scanned
|
file
|
18.3 KB
|
TestPurgatoryPerformance.java
|
.java
|
Java
|
text/x-c
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher
|
scanned
|
directory
|
|
fetcher
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java
|
scanned
|
file
|
14.7 KB
|
ReplicaFetcherThreadBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetchsession
|
scanned
|
directory
|
|
fetchsession
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetchsession/FetchSessionBenchmark.java
|
scanned
|
file
|
4.9 KB
|
FetchSessionBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/log
|
scanned
|
directory
|
|
log
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/log/StressTestLog.java
|
scanned
|
file
|
8.0 KB
|
StressTestLog.java
|
.java
|
Java
|
text/x-c
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/log/TestLinearWriteSpeed.java
|
scanned
|
file
|
15.5 KB
|
TestLinearWriteSpeed.java
|
.java
|
Java
|
text/x-c
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/metadata
|
scanned
|
directory
|
|
metadata
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/metadata/KRaftMetadataRequestBenchmark.java
|
scanned
|
file
|
11.9 KB
|
KRaftMetadataRequestBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/metadata/TopicsImageSingleRecordChangeBenchmark.java
|
scanned
|
file
|
3.6 KB
|
TopicsImageSingleRecordChangeBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/metadata/TopicsImageSnapshotLoadBenchmark.java
|
scanned
|
file
|
5.0 KB
|
TopicsImageSnapshotLoadBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/metadata/TopicsImageZonalOutageBenchmark.java
|
scanned
|
file
|
4.2 KB
|
TopicsImageZonalOutageBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/metrics
|
scanned
|
directory
|
|
metrics
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/metrics/HistogramBenchmark.java
|
scanned
|
file
|
4.4 KB
|
HistogramBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition
|
scanned
|
directory
|
|
partition
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/PartitionMakeFollowerBenchmark.java
|
scanned
|
file
|
7.2 KB
|
PartitionMakeFollowerBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/UpdateFollowerFetchStateBenchmark.java
|
scanned
|
file
|
7.5 KB
|
UpdateFollowerFetchStateBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/producer
|
scanned
|
directory
|
|
producer
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/producer/ProducerRecordBenchmark.java
|
scanned
|
file
|
1.7 KB
|
ProducerRecordBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/producer/ProducerRequestBenchmark.java
|
scanned
|
file
|
3.6 KB
|
ProducerRequestBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/producer/ProducerResponseBenchmark.java
|
scanned
|
file
|
3.2 KB
|
ProducerResponseBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/producer/RecordAccumulatorFlushBenchmark.java
|
scanned
|
file
|
6.3 KB
|
RecordAccumulatorFlushBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/record
|
scanned
|
directory
|
|
record
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/record/BaseRecordBatchBenchmark.java
|
scanned
|
file
|
5.7 KB
|
BaseRecordBatchBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/record/CompressedRecordBatchValidationBenchmark.java
|
scanned
|
file
|
2.6 KB
|
CompressedRecordBatchValidationBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/record/RecordBatchIterationBenchmark.java
|
scanned
|
file
|
3.6 KB
|
RecordBatchIterationBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/record/UncompressedRecordBatchValidationBenchmark.java
|
scanned
|
file
|
2.4 KB
|
UncompressedRecordBatchValidationBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/server
|
scanned
|
directory
|
|
server
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/server/CheckpointBench.java
|
scanned
|
file
|
6.9 KB
|
CheckpointBench.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/server/PartitionCreationBench.java
|
scanned
|
file
|
8.2 KB
|
PartitionCreationBench.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|