|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/common/errors/TransactionExceptionHierarchyTest.java
|
scanned
|
file
|
5.1 KB
|
TransactionExceptionHierarchyTest.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/common/feature
|
scanned
|
directory
|
|
feature
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/common/feature/FeaturesTest.java
|
scanned
|
file
|
5.8 KB
|
FeaturesTest.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/common/feature/SupportedVersionRangeTest.java
|
scanned
|
file
|
6.3 KB
|
SupportedVersionRangeTest.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/common/header
|
scanned
|
directory
|
|
header
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/common/header/internals
|
scanned
|
directory
|
|
internals
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/common/header/internals/RecordHeadersTest.java
|
scanned
|
file
|
10.6 KB
|
RecordHeadersTest.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/common/internals
|
scanned
|
directory
|
|
internals
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/common/internals/IdempotentCloserTest.java
|
scanned
|
file
|
7.2 KB
|
IdempotentCloserTest.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/common/internals/PartitionStatesTest.java
|
scanned
|
file
|
9.0 KB
|
PartitionStatesTest.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/common/internals/PluginTest.java
|
scanned
|
file
|
6.4 KB
|
PluginTest.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/common/internals/SecurityManagerCompatibilityTest.java
|
scanned
|
file
|
9.6 KB
|
SecurityManagerCompatibilityTest.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/common/internals/TopicTest.java
|
scanned
|
file
|
4.3 KB
|
TopicTest.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/common/KafkaFutureTest.java
|
scanned
|
file
|
27.8 KB
|
KafkaFutureTest.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/common/memory
|
scanned
|
directory
|
|
memory
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/common/memory/GarbageCollectedMemoryPoolTest.java
|
scanned
|
file
|
6.3 KB
|
GarbageCollectedMemoryPoolTest.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/common/message
|
scanned
|
directory
|
|
message
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/common/message/ApiMessageTypeTest.java
|
scanned
|
file
|
6.0 KB
|
ApiMessageTypeTest.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/common/message/MessageTest.java
|
scanned
|
file
|
46.7 KB
|
MessageTest.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/common/message/NullableStructMessageTest.java
|
scanned
|
file
|
5.7 KB
|
NullableStructMessageTest.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/common/message/RecordsSerdeTest.java
|
scanned
|
file
|
3.1 KB
|
RecordsSerdeTest.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/common/message/SimpleArraysMessageTest.java
|
scanned
|
file
|
2.6 KB
|
SimpleArraysMessageTest.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/common/message/SimpleExampleMessageTest.java
|
scanned
|
file
|
16.6 KB
|
SimpleExampleMessageTest.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/common/metrics
|
scanned
|
directory
|
|
metrics
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/common/metrics/FakeMetricsReporter.java
|
scanned
|
file
|
1.2 KB
|
FakeMetricsReporter.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/common/metrics/internals
|
scanned
|
directory
|
|
internals
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/common/metrics/internals/IntGaugeSuiteTest.java
|
scanned
|
file
|
3.5 KB
|
IntGaugeSuiteTest.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/common/metrics/internals/MetricsUtilsTest.java
|
scanned
|
file
|
1.5 KB
|
MetricsUtilsTest.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/common/metrics/internals/PluginMetricsImplTest.java
|
scanned
|
file
|
4.8 KB
|
PluginMetricsImplTest.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/common/metrics/JmxReporterTest.java
|
scanned
|
file
|
8.6 KB
|
JmxReporterTest.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/common/metrics/KafkaMbeanTest.java
|
scanned
|
file
|
6.0 KB
|
KafkaMbeanTest.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/common/metrics/KafkaMetricsContextTest.java
|
scanned
|
file
|
3.2 KB
|
KafkaMetricsContextTest.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/common/metrics/KafkaMetricTest.java
|
scanned
|
file
|
3.1 KB
|
KafkaMetricTest.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/common/metrics/MetricsTest.java
|
scanned
|
file
|
41.0 KB
|
MetricsTest.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/common/metrics/SampleMetrics.java
|
scanned
|
file
|
1.5 KB
|
SampleMetrics.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/common/metrics/SensorTest.java
|
scanned
|
file
|
15.6 KB
|
SensorTest.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/common/metrics/stats
|
scanned
|
directory
|
|
stats
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/common/metrics/stats/FrequenciesTest.java
|
scanned
|
file
|
6.8 KB
|
FrequenciesTest.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/common/metrics/stats/HistogramTest.java
|
scanned
|
file
|
8.8 KB
|
HistogramTest.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/common/metrics/stats/MeterTest.java
|
scanned
|
file
|
3.1 KB
|
MeterTest.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/common/metrics/stats/RateTest.java
|
scanned
|
file
|
4.7 KB
|
RateTest.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/common/metrics/stats/SampledStatTest.java
|
scanned
|
file
|
3.7 KB
|
SampledStatTest.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/common/metrics/TokenBucketTest.java
|
scanned
|
file
|
3.3 KB
|
TokenBucketTest.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/common/network
|
scanned
|
directory
|
|
network
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/common/network/CertStores.java
|
scanned
|
file
|
5.5 KB
|
CertStores.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/common/network/ChannelBuildersTest.java
|
scanned
|
file
|
6.2 KB
|
ChannelBuildersTest.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/common/network/DefaultChannelMetadataRegistry.java
|
scanned
|
file
|
1.6 KB
|
DefaultChannelMetadataRegistry.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/common/network/EchoServer.java
|
scanned
|
file
|
5.8 KB
|
EchoServer.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/common/network/KafkaChannelTest.java
|
scanned
|
file
|
4.8 KB
|
KafkaChannelTest.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/common/network/NetworkReceiveTest.java
|
scanned
|
file
|
4.8 KB
|
NetworkReceiveTest.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/common/network/NetworkTestUtils.java
|
scanned
|
file
|
6.7 KB
|
NetworkTestUtils.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/common/network/NioEchoServer.java
|
scanned
|
file
|
17.0 KB
|
NioEchoServer.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/common/network/PlaintextSender.java
|
scanned
|
file
|
1.6 KB
|
PlaintextSender.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/common/network/SaslChannelBuilderTest.java
|
scanned
|
file
|
10.6 KB
|
SaslChannelBuilderTest.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/common/network/SelectorTest.java
|
scanned
|
file
|
50.5 KB
|
SelectorTest.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/common/network/ServerConnectionIdTest.java
|
scanned
|
file
|
9.6 KB
|
ServerConnectionIdTest.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/common/network/SslSelectorTest.java
|
scanned
|
file
|
16.9 KB
|
SslSelectorTest.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/common/network/SslSender.java
|
scanned
|
file
|
3.1 KB
|
SslSender.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/common/network/SslTransportLayerTest.java
|
scanned
|
file
|
81.5 KB
|
SslTransportLayerTest.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/common/network/SslTransportTls12Tls13Test.java
|
scanned
|
file
|
7.7 KB
|
SslTransportTls12Tls13Test.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/common/network/SslVersionsTransportLayerTest.java
|
scanned
|
file
|
9.1 KB
|
SslVersionsTransportLayerTest.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/common/network/Tls12SelectorTest.java
|
scanned
|
file
|
2.8 KB
|
Tls12SelectorTest.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/common/network/Tls13SelectorTest.java
|
scanned
|
file
|
4.0 KB
|
Tls13SelectorTest.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/common/PartitionInfoTest.java
|
scanned
|
file
|
1.8 KB
|
PartitionInfoTest.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/common/protocol
|
scanned
|
directory
|
|
protocol
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/common/protocol/ApiKeysTest.java
|
scanned
|
file
|
4.8 KB
|
ApiKeysTest.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/common/protocol/ByteBufferAccessorTest.java
|
scanned
|
file
|
2.4 KB
|
ByteBufferAccessorTest.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/common/protocol/DataOutputStreamWritableTest.java
|
scanned
|
file
|
2.9 KB
|
DataOutputStreamWritableTest.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/common/protocol/ErrorsTest.java
|
scanned
|
file
|
3.4 KB
|
ErrorsTest.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/common/protocol/MessageUtilTest.java
|
scanned
|
file
|
4.9 KB
|
MessageUtilTest.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/common/protocol/ProtocolTest.java
|
scanned
|
file
|
1.9 KB
|
ProtocolTest.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/common/protocol/ProtoUtilsTest.java
|
scanned
|
file
|
2.1 KB
|
ProtoUtilsTest.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/common/protocol/SendBuilderTest.java
|
scanned
|
file
|
5.9 KB
|
SendBuilderTest.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/common/protocol/types
|
scanned
|
directory
|
|
types
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/common/protocol/types/ProtocolSerializationTest.java
|
scanned
|
file
|
20.6 KB
|
ProtocolSerializationTest.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/common/protocol/types/RawTaggedFieldWriterTest.java
|
scanned
|
file
|
4.1 KB
|
RawTaggedFieldWriterTest.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/common/protocol/types/StructTest.java
|
scanned
|
file
|
3.6 KB
|
StructTest.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/common/protocol/types/TypeTest.java
|
scanned
|
file
|
3.5 KB
|
TypeTest.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/common/record
|
scanned
|
directory
|
|
record
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/common/record/AbstractLegacyRecordBatchTest.java
|
scanned
|
file
|
11.7 KB
|
AbstractLegacyRecordBatchTest.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/common/record/ArbitraryMemoryRecords.java
|
scanned
|
file
|
1.5 KB
|
ArbitraryMemoryRecords.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/common/record/BufferSupplierTest.java
|
scanned
|
file
|
1.7 KB
|
BufferSupplierTest.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/common/record/ByteBufferLogInputStreamTest.java
|
scanned
|
file
|
5.2 KB
|
ByteBufferLogInputStreamTest.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/common/record/CompressionRatioEstimatorTest.java
|
scanned
|
file
|
2.6 KB
|
CompressionRatioEstimatorTest.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/common/record/ControlRecordTypeTest.java
|
scanned
|
file
|
2.2 KB
|
ControlRecordTypeTest.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/common/record/ControlRecordUtilsTest.java
|
scanned
|
file
|
3.9 KB
|
ControlRecordUtilsTest.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/common/record/DefaultRecordBatchTest.java
|
scanned
|
file
|
28.4 KB
|
DefaultRecordBatchTest.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/common/record/DefaultRecordTest.java
|
scanned
|
file
|
20.6 KB
|
DefaultRecordTest.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/common/record/EndTransactionMarkerTest.java
|
scanned
|
file
|
6.6 KB
|
EndTransactionMarkerTest.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/common/record/FileLogInputStreamTest.java
|
scanned
|
file
|
14.7 KB
|
FileLogInputStreamTest.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/common/record/FileRecordsTest.java
|
scanned
|
file
|
35.2 KB
|
FileRecordsTest.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/common/record/InvalidMemoryRecordsProvider.java
|
scanned
|
file
|
4.9 KB
|
InvalidMemoryRecordsProvider.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/common/record/LegacyRecordTest.java
|
scanned
|
file
|
5.9 KB
|
LegacyRecordTest.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/common/record/MemoryRecordsBuilderTest.java
|
scanned
|
file
|
30.8 KB
|
MemoryRecordsBuilderTest.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/common/record/MemoryRecordsTest.java
|
scanned
|
file
|
58.9 KB
|
MemoryRecordsTest.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/common/record/MultiRecordsSendTest.java
|
scanned
|
file
|
2.9 KB
|
MultiRecordsSendTest.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/common/record/RemoteLogInputStreamTest.java
|
scanned
|
file
|
13.3 KB
|
RemoteLogInputStreamTest.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/common/record/SimpleLegacyRecordTest.java
|
scanned
|
file
|
3.8 KB
|
SimpleLegacyRecordTest.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/common/record/UnalignedFileRecordsTest.java
|
scanned
|
file
|
2.8 KB
|
UnalignedFileRecordsTest.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/common/replica
|
scanned
|
directory
|
|
replica
|
|
|
|
|
|
|
|