|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/docs/streams/developer-guide/security.md
|
scanned
|
file
|
10.1 KB
|
security.md
|
.md
|
|
text/html
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/docs/streams/developer-guide/streams-rebalance-protocol.md
|
scanned
|
file
|
18.3 KB
|
streams-rebalance-protocol.md
|
.md
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/docs/streams/developer-guide/testing.md
|
scanned
|
file
|
14.1 KB
|
testing.md
|
.md
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/docs/streams/developer-guide/write-streams-app.md
|
scanned
|
file
|
7.7 KB
|
write-streams-app.md
|
.md
|
|
text/html
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/docs/streams/_index.md
|
scanned
|
file
|
898 bytes
|
_index.md
|
.md
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/docs/streams/introduction.md
|
scanned
|
file
|
5.4 KB
|
introduction.md
|
.md
|
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/docs/streams/quickstart.md
|
scanned
|
file
|
13.8 KB
|
quickstart.md
|
.md
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/docs/streams/tutorial.md
|
scanned
|
file
|
24.6 KB
|
tutorial.md
|
.md
|
|
text/x-c
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/docs/streams/upgrade-guide.md
|
scanned
|
file
|
74.1 KB
|
upgrade-guide.md
|
.md
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/examples/bin/exactly-once-demo.sh
|
scanned
|
file
|
981 bytes
|
exactly-once-demo.sh
|
.sh
|
Bash
|
text/x-shellscript
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/examples/bin/java-producer-consumer-demo.sh
|
scanned
|
file
|
987 bytes
|
java-producer-consumer-demo.sh
|
.sh
|
Bash
|
text/x-shellscript
|
|
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
|
|
|
|
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/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/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/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/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/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/ClassicGroup.java
|
scanned
|
file
|
51.1 KB
|
ClassicGroup.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/ClassicGroupMember.java
|
scanned
|
file
|
12.5 KB
|
ClassicGroupMember.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/ClassicGroupState.java
|
scanned
|
file
|
5.8 KB
|
ClassicGroupState.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|