|
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
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/FieldSpec.java
|
scanned
|
file
|
27.7 KB
|
FieldSpec.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/FieldType.java
|
scanned
|
file
|
13.4 KB
|
FieldType.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/HeaderGenerator.java
|
scanned
|
file
|
3.3 KB
|
HeaderGenerator.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/IsNullConditional.java
|
scanned
|
file
|
4.5 KB
|
IsNullConditional.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/JsonConverterGenerator.java
|
scanned
|
file
|
24.2 KB
|
JsonConverterGenerator.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/MessageClassGenerator.java
|
scanned
|
file
|
1.3 KB
|
MessageClassGenerator.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/MessageDataGenerator.java
|
scanned
|
file
|
88.5 KB
|
MessageDataGenerator.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/MessageGenerator.java
|
scanned
|
file
|
16.6 KB
|
MessageGenerator.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/MessageSpec.java
|
scanned
|
file
|
7.1 KB
|
MessageSpec.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/MessageSpecType.java
|
scanned
|
file
|
1.4 KB
|
MessageSpecType.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/MetadataJsonConvertersGenerator.java
|
scanned
|
file
|
5.0 KB
|
MetadataJsonConvertersGenerator.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/MetadataRecordTypeGenerator.java
|
scanned
|
file
|
7.2 KB
|
MetadataRecordTypeGenerator.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/RequestListenerType.java
|
scanned
|
file
|
1014 bytes
|
RequestListenerType.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/SchemaGenerator.java
|
scanned
|
file
|
15.5 KB
|
SchemaGenerator.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/StructRegistry.java
|
scanned
|
file
|
7.1 KB
|
StructRegistry.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/StructSpec.java
|
scanned
|
file
|
4.1 KB
|
StructSpec.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/Target.java
|
scanned
|
file
|
3.4 KB
|
Target.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/TypeClassGenerator.java
|
scanned
|
file
|
1.4 KB
|
TypeClassGenerator.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/VersionConditional.java
|
scanned
|
file
|
9.0 KB
|
VersionConditional.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/Versions.java
|
scanned
|
file
|
6.7 KB
|
Versions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test
|
scanned
|
directory
|
|
test
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java
|
scanned
|
directory
|
|
java
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org
|
scanned
|
directory
|
|
org
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache
|
scanned
|
directory
|
|
apache
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka
|
scanned
|
directory
|
|
kafka
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message
|
scanned
|
directory
|
|
message
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/checker
|
scanned
|
directory
|
|
checker
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/checker/CheckerTestUtils.java
|
scanned
|
file
|
3.9 KB
|
CheckerTestUtils.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/checker/CheckerUtilsTest.java
|
scanned
|
file
|
3.1 KB
|
CheckerUtilsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/checker/EvolutionVerifierTest.java
|
scanned
|
file
|
11.1 KB
|
EvolutionVerifierTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/checker/FieldDomainTest.java
|
scanned
|
file
|
2.1 KB
|
FieldDomainTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/checker/MetadataSchemaCheckerToolTest.java
|
scanned
|
file
|
4.0 KB
|
MetadataSchemaCheckerToolTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/checker/UnifierTest.java
|
scanned
|
file
|
10.4 KB
|
UnifierTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/CodeBufferTest.java
|
scanned
|
file
|
2.7 KB
|
CodeBufferTest.java
|
.java
|
Java
|
text/x-c
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/EntityTypeTest.java
|
scanned
|
file
|
3.7 KB
|
EntityTypeTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/IsNullConditionalTest.java
|
scanned
|
file
|
4.3 KB
|
IsNullConditionalTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/MessageDataGeneratorTest.java
|
scanned
|
file
|
15.0 KB
|
MessageDataGeneratorTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/MessageGeneratorTest.java
|
scanned
|
file
|
6.4 KB
|
MessageGeneratorTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/StructRegistryTest.java
|
scanned
|
file
|
8.0 KB
|
StructRegistryTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/StructSpecTest.java
|
scanned
|
file
|
3.2 KB
|
StructSpecTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/VersionConditionalTest.java
|
scanned
|
file
|
8.8 KB
|
VersionConditionalTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/VersionsTest.java
|
scanned
|
file
|
4.6 KB
|
VersionsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/gradle
|
scanned
|
directory
|
|
gradle
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/gradle/dependencies.gradle
|
scanned
|
file
|
11.9 KB
|
dependencies.gradle
|
.gradle
|
Groovy
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/gradle/openapi.template
|
scanned
|
file
|
1.1 KB
|
openapi.template
|
.template
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/gradle.properties
|
scanned
|
file
|
1.4 KB
|
gradle.properties
|
.properties
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/gradle/resources
|
scanned
|
directory
|
|
resources
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/gradle/resources/dependencycheck-suppressions.xml
|
scanned
|
file
|
1.2 KB
|
dependencycheck-suppressions.xml
|
.xml
|
|
text/xml
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/gradle/resources/rat-output-to-html.xsl
|
scanned
|
file
|
6.9 KB
|
rat-output-to-html.xsl
|
.xsl
|
|
text/html
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/gradle/spotbugs-exclude.xml
|
scanned
|
file
|
36.5 KB
|
spotbugs-exclude.xml
|
.xml
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/gradlew
|
scanned
|
file
|
10.0 KB
|
gradlew
|
|
Bash
|
text/x-shellscript
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/gradlewAll
|
scanned
|
file
|
1.2 KB
|
gradlewAll
|
|
Bash
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/gradle/wrapper
|
scanned
|
directory
|
|
wrapper
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/gradle/wrapper/gradle-wrapper.properties
|
scanned
|
file
|
339 bytes
|
gradle-wrapper.properties
|
.properties
|
|
text/plain
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/gradle/wrapper/README.md
|
scanned
|
file
|
1.3 KB
|
README.md
|
.md
|
|
text/plain
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator
|
scanned
|
directory
|
|
group-coordinator
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/.gitignore
|
scanned
|
file
|
6 bytes
|
.gitignore
|
|
|
text/plain
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api
|
scanned
|
directory
|
|
group-coordinator-api
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src
|
scanned
|
directory
|
|
src
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main
|
scanned
|
directory
|
|
main
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java
|
scanned
|
directory
|
|
java
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org
|
scanned
|
directory
|
|
org
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache
|
scanned
|
directory
|
|
apache
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka
|
scanned
|
directory
|
|
kafka
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator
|
scanned
|
directory
|
|
coordinator
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group
|
scanned
|
directory
|
|
group
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api
|
scanned
|
directory
|
|
api
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor
|
scanned
|
directory
|
|
assignor
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/ConsumerGroupPartitionAssignor.java
|
scanned
|
file
|
1.0 KB
|
ConsumerGroupPartitionAssignor.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/GroupAssignment.java
|
scanned
|
file
|
1.8 KB
|
GroupAssignment.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/GroupSpec.java
|
scanned
|
file
|
2.8 KB
|
GroupSpec.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/MemberAssignment.java
|
scanned
|
file
|
1.1 KB
|
MemberAssignment.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/MemberSubscription.java
|
scanned
|
file
|
1.5 KB
|
MemberSubscription.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/package-info.java
|
scanned
|
file
|
964 bytes
|
package-info.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/PartitionAssignorException.java
|
scanned
|
file
|
1.3 KB
|
PartitionAssignorException.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/PartitionAssignor.java
|
scanned
|
file
|
1.5 KB
|
PartitionAssignor.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/ShareGroupPartitionAssignor.java
|
scanned
|
file
|
1021 bytes
|
ShareGroupPartitionAssignor.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/SubscribedTopicDescriber.java
|
scanned
|
file
|
1.8 KB
|
SubscribedTopicDescriber.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/SubscriptionType.java
|
scanned
|
file
|
1.4 KB
|
SubscriptionType.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src
|
scanned
|
directory
|
|
src
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main
|
scanned
|
directory
|
|
main
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java
|
scanned
|
directory
|
|
java
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org
|
scanned
|
directory
|
|
org
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache
|
scanned
|
directory
|
|
apache
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka
|
scanned
|
directory
|
|
kafka
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator
|
scanned
|
directory
|
|
coordinator
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group
|
scanned
|
directory
|
|
group
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor
|
scanned
|
directory
|
|
assignor
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/AssignorHelpers.java
|
scanned
|
file
|
2.8 KB
|
AssignorHelpers.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/RangeAssignor.java
|
scanned
|
file
|
12.9 KB
|
RangeAssignor.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/RangeSet.java
|
scanned
|
file
|
5.9 KB
|
RangeSet.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/SimpleAssignor.java
|
scanned
|
file
|
3.6 KB
|
SimpleAssignor.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/SimpleHeterogeneousAssignmentBuilder.java
|
scanned
|
file
|
22.5 KB
|
SimpleHeterogeneousAssignmentBuilder.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/SimpleHomogeneousAssignmentBuilder.java
|
scanned
|
file
|
19.6 KB
|
SimpleHomogeneousAssignmentBuilder.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformAssignor.java
|
scanned
|
file
|
3.8 KB
|
UniformAssignor.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformHeterogeneousAssignmentBuilder.java
|
scanned
|
file
|
39.1 KB
|
UniformHeterogeneousAssignmentBuilder.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformHomogeneousAssignmentBuilder.java
|
scanned
|
file
|
11.7 KB
|
UniformHomogeneousAssignmentBuilder.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/classic
|
scanned
|
directory
|
|
classic
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/classic/ClassicGroup.java
|
scanned
|
file
|
51.1 KB
|
ClassicGroup.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|