|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRecordSerde.java
|
scanned
|
file
|
4.9 KB
|
CoordinatorRecordSerde.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorResult.java
|
scanned
|
file
|
6.3 KB
|
CoordinatorResult.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRuntime.java
|
scanned
|
file
|
96.5 KB
|
CoordinatorRuntime.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRuntimeMetricsImpl.java
|
scanned
|
file
|
11.9 KB
|
CoordinatorRuntimeMetricsImpl.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRuntimeMetrics.java
|
scanned
|
file
|
2.8 KB
|
CoordinatorRuntimeMetrics.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorShardBuilder.java
|
scanned
|
file
|
3.0 KB
|
CoordinatorShardBuilder.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorShardBuilderSupplier.java
|
scanned
|
file
|
1.2 KB
|
CoordinatorShardBuilderSupplier.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorShard.java
|
scanned
|
file
|
2.7 KB
|
CoordinatorShard.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorTimer.java
|
scanned
|
file
|
3.9 KB
|
CoordinatorTimer.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/Deserializer.java
|
scanned
|
file
|
2.3 KB
|
Deserializer.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/EventAccumulator.java
|
scanned
|
file
|
7.8 KB
|
EventAccumulator.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/HdrHistogram.java
|
scanned
|
file
|
5.2 KB
|
HdrHistogram.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/KafkaMetricHistogram.java
|
scanned
|
file
|
5.2 KB
|
KafkaMetricHistogram.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/KRaftCoordinatorMetadataDelta.java
|
scanned
|
file
|
2.6 KB
|
KRaftCoordinatorMetadataDelta.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/KRaftCoordinatorMetadataImage.java
|
scanned
|
file
|
4.8 KB
|
KRaftCoordinatorMetadataImage.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/MultiThreadedEventProcessor.java
|
scanned
|
file
|
8.5 KB
|
MultiThreadedEventProcessor.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/PartitionWriter.java
|
scanned
|
file
|
4.3 KB
|
PartitionWriter.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/Serializer.java
|
scanned
|
file
|
1.1 KB
|
Serializer.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/SnapshottableCoordinator.java
|
scanned
|
file
|
7.3 KB
|
SnapshottableCoordinator.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/CoordinatorExecutorImplTest.java
|
scanned
|
file
|
14.4 KB
|
CoordinatorExecutorImplTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/CoordinatorLoaderImplTest.java
|
scanned
|
file
|
35.2 KB
|
CoordinatorLoaderImplTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRecordTest.java
|
scanned
|
file
|
2.4 KB
|
CoordinatorRecordTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/CoordinatorResultTest.java
|
scanned
|
file
|
1.8 KB
|
CoordinatorResultTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRuntimeMetricsImplTest.java
|
scanned
|
file
|
18.4 KB
|
CoordinatorRuntimeMetricsImplTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRuntimeTest.java
|
scanned
|
file
|
267.0 KB
|
CoordinatorRuntimeTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/DirectEventProcessor.java
|
scanned
|
file
|
2.1 KB
|
DirectEventProcessor.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/EventAccumulatorTest.java
|
scanned
|
file
|
9.0 KB
|
EventAccumulatorTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/HdrHistogramTest.java
|
scanned
|
file
|
9.5 KB
|
HdrHistogramTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/InMemoryPartitionWriter.java
|
scanned
|
file
|
5.5 KB
|
InMemoryPartitionWriter.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/KafkaMetricHistogramTest.java
|
scanned
|
file
|
2.3 KB
|
KafkaMetricHistogramTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/KRaftCoordinatorMetadataDeltaTest.java
|
scanned
|
file
|
6.3 KB
|
KRaftCoordinatorMetadataDeltaTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/KRaftCoordinatorMetadataImageTest.java
|
scanned
|
file
|
6.0 KB
|
KRaftCoordinatorMetadataImageTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/ManualEventProcessor.java
|
scanned
|
file
|
1.8 KB
|
ManualEventProcessor.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/MetadataImageBuilder.java
|
scanned
|
file
|
2.9 KB
|
MetadataImageBuilder.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/MockCoordinatorExecutor.java
|
scanned
|
file
|
3.3 KB
|
MockCoordinatorExecutor.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/MockCoordinatorLoader.java
|
scanned
|
file
|
2.0 KB
|
MockCoordinatorLoader.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/MockCoordinatorShardBuilder.java
|
scanned
|
file
|
2.9 KB
|
MockCoordinatorShardBuilder.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/MockCoordinatorShardBuilderSupplier.java
|
scanned
|
file
|
1.2 KB
|
MockCoordinatorShardBuilderSupplier.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/MockCoordinatorShard.java
|
scanned
|
file
|
4.5 KB
|
MockCoordinatorShard.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/MockCoordinatorTimer.java
|
scanned
|
file
|
4.6 KB
|
MockCoordinatorTimer.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/MockPartitionWriter.java
|
scanned
|
file
|
5.8 KB
|
MockPartitionWriter.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/MultiThreadedEventProcessorTest.java
|
scanned
|
file
|
19.8 KB
|
MultiThreadedEventProcessorTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/SnapshottableCoordinatorTest.java
|
scanned
|
file
|
6.5 KB
|
SnapshottableCoordinatorTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/StringSerializer.java
|
scanned
|
file
|
1.2 KB
|
StringSerializer.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/TestUtil.java
|
scanned
|
file
|
6.6 KB
|
TestUtil.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/ThrowingSerializer.java
|
scanned
|
file
|
1.7 KB
|
ThrowingSerializer.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/main/java/kafka/docker/Log4jConfiguration.java
|
scanned
|
file
|
5.7 KB
|
Log4jConfiguration.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/main/java/kafka/server/builders/KafkaApisBuilder.java
|
scanned
|
file
|
9.5 KB
|
KafkaApisBuilder.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/main/java/kafka/server/builders/LogManagerBuilder.java
|
scanned
|
file
|
7.4 KB
|
LogManagerBuilder.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/main/java/kafka/server/builders/ReplicaManagerBuilder.java
|
scanned
|
file
|
5.3 KB
|
ReplicaManagerBuilder.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/main/java/kafka/server/ClientRequestQuotaManager.java
|
scanned
|
file
|
4.9 KB
|
ClientRequestQuotaManager.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/main/java/kafka/server/handlers/DescribeTopicPartitionsRequestHandler.java
|
scanned
|
file
|
5.9 KB
|
DescribeTopicPartitionsRequestHandler.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/main/java/kafka/server/logger/RuntimeLoggerManager.java
|
scanned
|
file
|
6.2 KB
|
RuntimeLoggerManager.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/main/java/kafka/server/NetworkUtils.java
|
scanned
|
file
|
3.3 KB
|
NetworkUtils.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/main/java/kafka/server/QuotaFactory.java
|
scanned
|
file
|
5.6 KB
|
QuotaFactory.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/main/java/kafka/server/ReplicaQuota.java
|
scanned
|
file
|
1019 bytes
|
ReplicaQuota.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/main/java/kafka/server/ReplicationQuotaManager.java
|
scanned
|
file
|
5.7 KB
|
ReplicationQuotaManager.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/main/java/kafka/server/share/DelayedShareFetch.java
|
scanned
|
file
|
54.1 KB
|
DelayedShareFetch.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/main/java/kafka/server/share/PendingRemoteFetches.java
|
scanned
|
file
|
3.5 KB
|
PendingRemoteFetches.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/main/java/kafka/server/share/ShareCoordinatorMetadataCacheHelperImpl.java
|
scanned
|
file
|
4.6 KB
|
ShareCoordinatorMetadataCacheHelperImpl.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/main/java/kafka/server/share/ShareFetchUtils.java
|
scanned
|
file
|
16.5 KB
|
ShareFetchUtils.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/main/java/kafka/server/share/SharePartitionCache.java
|
scanned
|
file
|
4.8 KB
|
SharePartitionCache.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/main/java/kafka/server/share/SharePartition.java
|
scanned
|
file
|
182.1 KB
|
SharePartition.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/main/java/kafka/server/share/SharePartitionManager.java
|
scanned
|
file
|
44.6 KB
|
SharePartitionManager.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/main/java/kafka/server/TierStateMachine.java
|
scanned
|
file
|
15.2 KB
|
TierStateMachine.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/java/kafka/security/JaasModule.java
|
scanned
|
file
|
4.2 KB
|
JaasModule.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/java/kafka/security/JaasTestUtils.java
|
scanned
|
file
|
16.9 KB
|
JaasTestUtils.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/java/kafka/security/minikdc/MiniKdc.java
|
scanned
|
file
|
21.6 KB
|
MiniKdc.java
|
.java
|
Java
|
text/x-c
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/java/kafka/security/minikdc/MiniKdcTest.java
|
scanned
|
file
|
2.0 KB
|
MiniKdcTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/java/kafka/server/handlers/DescribeTopicPartitionsRequestHandlerTest.java
|
scanned
|
file
|
26.6 KB
|
DescribeTopicPartitionsRequestHandlerTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/java/kafka/server/logger/RuntimeLoggerManagerTest.java
|
scanned
|
file
|
4.2 KB
|
RuntimeLoggerManagerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/java/kafka/server/share/DelayedShareFetchTest.java
|
scanned
|
file
|
120.2 KB
|
DelayedShareFetchTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/java/kafka/server/share/ShareCoordinatorMetadataCacheHelperImplTest.java
|
scanned
|
file
|
15.9 KB
|
ShareCoordinatorMetadataCacheHelperImplTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/java/kafka/server/share/ShareFetchUtilsTest.java
|
scanned
|
file
|
43.5 KB
|
ShareFetchUtilsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/java/kafka/server/share/SharePartitionCacheTest.java
|
scanned
|
file
|
5.0 KB
|
SharePartitionCacheTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/java/kafka/server/share/SharePartitionManagerTest.java
|
scanned
|
file
|
176.5 KB
|
SharePartitionManagerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/java/kafka/server/share/SharePartitionTest.java
|
scanned
|
file
|
711.7 KB
|
SharePartitionTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/examples/src/main/java/kafka/examples/Consumer.java
|
scanned
|
file
|
8.2 KB
|
Consumer.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java
|
scanned
|
file
|
11.8 KB
|
ExactlyOnceMessageProcessor.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/examples/src/main/java/kafka/examples/KafkaConsumerProducerDemo.java
|
scanned
|
file
|
3.2 KB
|
KafkaConsumerProducerDemo.java
|
.java
|
Java
|
text/x-c
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/examples/src/main/java/kafka/examples/KafkaExactlyOnceDemo.java
|
scanned
|
file
|
5.9 KB
|
KafkaExactlyOnceDemo.java
|
.java
|
Java
|
text/x-c
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/examples/src/main/java/kafka/examples/KafkaProperties.java
|
scanned
|
file
|
960 bytes
|
KafkaProperties.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/examples/src/main/java/kafka/examples/Producer.java
|
scanned
|
file
|
8.3 KB
|
Producer.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/examples/src/main/java/kafka/examples/TransactionalClientDemo.java
|
scanned
|
file
|
10.5 KB
|
TransactionalClientDemo.java
|
.java
|
Java
|
text/html
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/examples/src/main/java/kafka/examples/Utils.java
|
scanned
|
file
|
4.6 KB
|
Utils.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/ApiMessageTypeGenerator.java
|
scanned
|
file
|
17.6 KB
|
ApiMessageTypeGenerator.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/checker/CheckerUtils.java
|
scanned
|
file
|
6.5 KB
|
CheckerUtils.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/checker/EvolutionException.java
|
scanned
|
file
|
1.1 KB
|
EvolutionException.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/checker/EvolutionVerifier.java
|
scanned
|
file
|
5.6 KB
|
EvolutionVerifier.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/checker/FieldDomain.java
|
scanned
|
file
|
4.1 KB
|
FieldDomain.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/checker/FieldSpecPairIterator.java
|
scanned
|
file
|
4.5 KB
|
FieldSpecPairIterator.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/checker/FieldSpecPair.java
|
scanned
|
file
|
1.4 KB
|
FieldSpecPair.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/checker/MetadataSchemaCheckerTool.java
|
scanned
|
file
|
4.9 KB
|
MetadataSchemaCheckerTool.java
|
.java
|
Java
|
text/x-c
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/checker/UnificationException.java
|
scanned
|
file
|
1.1 KB
|
UnificationException.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/checker/Unifier.java
|
scanned
|
file
|
9.8 KB
|
Unifier.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/ClauseGenerator.java
|
scanned
|
file
|
941 bytes
|
ClauseGenerator.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/CodeBuffer.java
|
scanned
|
file
|
2.1 KB
|
CodeBuffer.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/CoordinatorRecordJsonConvertersGenerator.java
|
scanned
|
file
|
8.6 KB
|
CoordinatorRecordJsonConvertersGenerator.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/CoordinatorRecordTypeGenerator.java
|
scanned
|
file
|
9.8 KB
|
CoordinatorRecordTypeGenerator.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/EntityType.java
|
scanned
|
file
|
2.1 KB
|
EntityType.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|