|
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/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/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/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/ReplicaSelectorTest.java
|
scanned
|
file
|
3.6 KB
|
ReplicaSelectorTest.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/requests/AddPartitionsToTxnRequestTest.java
|
scanned
|
file
|
8.3 KB
|
AddPartitionsToTxnRequestTest.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/requests/AddPartitionsToTxnResponseTest.java
|
scanned
|
file
|
7.4 KB
|
AddPartitionsToTxnResponseTest.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/requests/AlterPartitionRequestTest.java
|
scanned
|
file
|
4.0 KB
|
AlterPartitionRequestTest.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/requests/AlterReplicaLogDirsRequestTest.java
|
scanned
|
file
|
4.9 KB
|
AlterReplicaLogDirsRequestTest.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/requests/AlterReplicaLogDirsResponseTest.java
|
scanned
|
file
|
2.9 KB
|
AlterReplicaLogDirsResponseTest.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/requests/ApiErrorTest.java
|
scanned
|
file
|
3.7 KB
|
ApiErrorTest.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/requests/ApiVersionsResponseTest.java
|
scanned
|
file
|
12.9 KB
|
ApiVersionsResponseTest.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/requests/BrokerRegistrationRequestTest.java
|
scanned
|
file
|
7.1 KB
|
BrokerRegistrationRequestTest.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/requests/ByteBufferChannel.java
|
scanned
|
file
|
2.4 KB
|
ByteBufferChannel.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/requests/ByteBufferChannelTest.java
|
scanned
|
file
|
3.4 KB
|
ByteBufferChannelTest.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/requests/ConsumerGroupDescribeRequestTest.java
|
scanned
|
file
|
3.2 KB
|
ConsumerGroupDescribeRequestTest.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/requests/ConsumerGroupDescribeResponseTest.java
|
scanned
|
file
|
1.8 KB
|
ConsumerGroupDescribeResponseTest.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/requests/CreateAclsRequestTest.java
|
scanned
|
file
|
4.0 KB
|
CreateAclsRequestTest.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/requests/DeleteAclsRequestTest.java
|
scanned
|
file
|
4.3 KB
|
DeleteAclsRequestTest.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/requests/DeleteAclsResponseTest.java
|
scanned
|
file
|
4.6 KB
|
DeleteAclsResponseTest.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/requests/DeleteGroupsRequestTest.java
|
scanned
|
file
|
2.2 KB
|
DeleteGroupsRequestTest.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/requests/DeleteGroupsResponseTest.java
|
scanned
|
file
|
3.3 KB
|
DeleteGroupsResponseTest.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/requests/DeleteTopicsRequestTest.java
|
scanned
|
file
|
6.8 KB
|
DeleteTopicsRequestTest.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/requests/DescribeAclsRequestTest.java
|
scanned
|
file
|
3.3 KB
|
DescribeAclsRequestTest.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/requests/DescribeAclsResponseTest.java
|
scanned
|
file
|
5.6 KB
|
DescribeAclsResponseTest.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/requests/DescribeGroupsRequestTest.java
|
scanned
|
file
|
2.2 KB
|
DescribeGroupsRequestTest.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/requests/EndTxnRequestTest.java
|
scanned
|
file
|
3.6 KB
|
EndTxnRequestTest.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/requests/EndTxnResponseTest.java
|
scanned
|
file
|
2.2 KB
|
EndTxnResponseTest.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/requests/EnvelopeRequestTest.java
|
scanned
|
file
|
3.2 KB
|
EnvelopeRequestTest.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/requests/EnvelopeResponseTest.java
|
scanned
|
file
|
2.3 KB
|
EnvelopeResponseTest.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/requests/FetchRequestTest.java
|
scanned
|
file
|
17.9 KB
|
FetchRequestTest.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/requests/FindCoordinatorRequestTest.java
|
scanned
|
file
|
1.2 KB
|
FindCoordinatorRequestTest.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/requests/GetTelemetrySubscriptionsRequestTest.java
|
scanned
|
file
|
1.6 KB
|
GetTelemetrySubscriptionsRequestTest.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/requests/GetTelemetrySubscriptionsResponseTest.java
|
scanned
|
file
|
2.0 KB
|
GetTelemetrySubscriptionsResponseTest.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/requests/HeartbeatRequestTest.java
|
scanned
|
file
|
1.4 KB
|
HeartbeatRequestTest.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/requests/JoinGroupRequestTest.java
|
scanned
|
file
|
3.3 KB
|
JoinGroupRequestTest.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/requests/JoinGroupResponseTest.java
|
scanned
|
file
|
2.3 KB
|
JoinGroupResponseTest.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/requests/LeaveGroupRequestTest.java
|
scanned
|
file
|
5.3 KB
|
LeaveGroupRequestTest.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/requests/LeaveGroupResponseTest.java
|
scanned
|
file
|
9.8 KB
|
LeaveGroupResponseTest.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/requests/ListOffsetsRequestTest.java
|
scanned
|
file
|
7.7 KB
|
ListOffsetsRequestTest.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/requests/MetadataRequestTest.java
|
scanned
|
file
|
5.3 KB
|
MetadataRequestTest.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/requests/MetadataResponseTest.java
|
scanned
|
file
|
3.0 KB
|
MetadataResponseTest.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/requests/OffsetCommitRequestTest.java
|
scanned
|
file
|
6.4 KB
|
OffsetCommitRequestTest.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/requests/OffsetCommitResponseTest.java
|
scanned
|
file
|
4.2 KB
|
OffsetCommitResponseTest.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/requests/OffsetFetchRequestTest.java
|
scanned
|
file
|
11.3 KB
|
OffsetFetchRequestTest.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/requests/OffsetFetchResponseTest.java
|
scanned
|
file
|
15.9 KB
|
OffsetFetchResponseTest.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/requests/OffsetsForLeaderEpochRequestTest.java
|
scanned
|
file
|
2.4 KB
|
OffsetsForLeaderEpochRequestTest.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/requests/ProduceRequestTest.java
|
scanned
|
file
|
17.7 KB
|
ProduceRequestTest.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/requests/ProduceResponseTest.java
|
scanned
|
file
|
5.2 KB
|
ProduceResponseTest.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/requests/PushTelemetryRequestTest.java
|
scanned
|
file
|
5.2 KB
|
PushTelemetryRequestTest.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/requests/PushTelemetryResponseTest.java
|
scanned
|
file
|
1.9 KB
|
PushTelemetryResponseTest.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/requests/RequestContextTest.java
|
scanned
|
file
|
9.5 KB
|
RequestContextTest.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/requests/RequestHeaderTest.java
|
scanned
|
file
|
5.2 KB
|
RequestHeaderTest.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/requests/RequestResponseTest.java
|
scanned
|
file
|
215.3 KB
|
RequestResponseTest.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/requests/RequestTestUtils.java
|
scanned
|
file
|
16.0 KB
|
RequestTestUtils.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/requests/RequestUtilsTest.java
|
scanned
|
file
|
2.3 KB
|
RequestUtilsTest.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/requests/SyncGroupRequestTest.java
|
scanned
|
file
|
1.4 KB
|
SyncGroupRequestTest.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/requests/TxnOffsetCommitRequestTest.java
|
scanned
|
file
|
7.2 KB
|
TxnOffsetCommitRequestTest.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/requests/TxnOffsetCommitResponseTest.java
|
scanned
|
file
|
2.9 KB
|
TxnOffsetCommitResponseTest.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/requests/UpdateFeaturesRequestTest.java
|
scanned
|
file
|
5.9 KB
|
UpdateFeaturesRequestTest.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/requests/UpdateFeaturesResponseTest.java
|
scanned
|
file
|
3.6 KB
|
UpdateFeaturesResponseTest.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/requests/WriteTxnMarkersRequestTest.java
|
scanned
|
file
|
12.4 KB
|
WriteTxnMarkersRequestTest.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/requests/WriteTxnMarkersResponseTest.java
|
scanned
|
file
|
2.6 KB
|
WriteTxnMarkersResponseTest.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/resource/ResourceTypeTest.java
|
scanned
|
file
|
3.6 KB
|
ResourceTypeTest.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/security/auth/DefaultKafkaPrincipalBuilderTest.java
|
scanned
|
file
|
8.4 KB
|
DefaultKafkaPrincipalBuilderTest.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/security/authenticator/ClientAuthenticationFailureTest.java
|
scanned
|
file
|
6.5 KB
|
ClientAuthenticationFailureTest.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/security/authenticator/LoginManagerTest.java
|
scanned
|
file
|
11.1 KB
|
LoginManagerTest.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/security/authenticator/SaslAuthenticatorFailureDelayTest.java
|
scanned
|
file
|
11.3 KB
|
SaslAuthenticatorFailureDelayTest.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/security/authenticator/SaslAuthenticatorFailureNoDelayTest.java
|
scanned
|
file
|
1.0 KB
|
SaslAuthenticatorFailureNoDelayTest.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/security/authenticator/SaslAuthenticatorFailurePositiveDelayTest.java
|
scanned
|
file
|
1.0 KB
|
SaslAuthenticatorFailurePositiveDelayTest.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/security/authenticator/SaslAuthenticatorTest.java
|
scanned
|
file
|
140.6 KB
|
SaslAuthenticatorTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|