6,866 results
« Page 29 of 69 »
Detected license expression: _ANY_
View the resource tree
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/versioned-predicate/test/plugins/VersionedPredicate.java scanned file 2.3 KB VersionedPredicate.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/versioned-sink-connector/META-INF/services/org.apache.kafka.connect.sink.SinkConnector scanned file 829 bytes org.apache.kafka.connect.sink.SinkConnector .SinkConnector text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/versioned-sink-connector/test/plugins/VersionedSinkConnector.java scanned file 3.2 KB VersionedSinkConnector.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/versioned-source-connector/META-INF/services/org.apache.kafka.connect.source.SourceConnector scanned file 831 bytes org.apache.kafka.connect.source.SourceConnector .SourceConnector text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/versioned-source-connector/test/plugins/VersionedSourceConnector.java scanned file 3.2 KB VersionedSourceConnector.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/versioned-transformation/META-INF/services/org.apache.kafka.connect.transforms.Transformation scanned file 830 bytes org.apache.kafka.connect.transforms.Transformation .Transformation text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/versioned-transformation/test/plugins/VersionedTransformation.java scanned file 2.3 KB VersionedTransformation.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/MockConnector.java scanned file 4.0 KB MockConnector.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/MockSinkConnector.java scanned file 2.4 KB MockSinkConnector.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/MockSinkTask.java scanned file 3.1 KB MockSinkTask.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/MockSourceConnector.java scanned file 2.4 KB MockSourceConnector.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/MockSourceTask.java scanned file 2.5 KB MockSourceTask.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/package-info.java scanned file 917 bytes package-info.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/SchemaSourceConnector.java scanned file 2.2 KB SchemaSourceConnector.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/SchemaSourceTask.java scanned file 6.6 KB SchemaSourceTask.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/VerifiableSinkConnector.java scanned file 2.1 KB VerifiableSinkConnector.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/VerifiableSinkTask.java scanned file 4.5 KB VerifiableSinkTask.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/VerifiableSourceConnector.java scanned file 2.1 KB VerifiableSourceConnector.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/VerifiableSourceTask.java scanned file 6.7 KB VerifiableSourceTask.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/resources/META-INF/services/org.apache.kafka.connect.sink.SinkConnector scanned file 897 bytes org.apache.kafka.connect.sink.SinkConnector .SinkConnector text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/resources/META-INF/services/org.apache.kafka.connect.source.SourceConnector scanned file 953 bytes org.apache.kafka.connect.source.SourceConnector .SourceConnector text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java scanned file 20.4 KB Cast.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/DropHeaders.java scanned file 2.9 KB DropHeaders.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ExtractField.java scanned file 5.9 KB ExtractField.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/field/FieldSyntaxVersion.java scanned file 4.1 KB FieldSyntaxVersion.java .java Java text/html apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/field/SingleFieldPath.java scanned file 9.0 KB SingleFieldPath.java .java Java text/html apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Filter.java scanned file 2.1 KB Filter.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Flatten.java scanned file 12.8 KB Flatten.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/HeaderFrom.java scanned file 10.6 KB HeaderFrom.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/HoistField.java scanned file 5.0 KB HoistField.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java scanned file 12.2 KB InsertField.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertHeader.java scanned file 3.1 KB InsertHeader.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/MaskField.java scanned file 9.2 KB MaskField.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/HasHeaderKey.java scanned file 2.6 KB HasHeaderKey.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/RecordIsTombstone.java scanned file 2.0 KB RecordIsTombstone.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/TopicNameMatches.java scanned file 3.2 KB TopicNameMatches.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/RegexRouter.java scanned file 3.6 KB RegexRouter.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ReplaceField.java scanned file 9.6 KB ReplaceField.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/SetSchemaMetadata.java scanned file 7.8 KB SetSchemaMetadata.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java scanned file 22.3 KB TimestampConverter.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampRouter.java scanned file 4.4 KB TimestampRouter.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/NonEmptyListValidator.java scanned file 1.3 KB NonEmptyListValidator.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/RegexValidator.java scanned file 1.4 KB RegexValidator.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/Requirements.java scanned file 2.8 KB Requirements.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/SchemaUtil.java scanned file 1.7 KB SchemaUtil.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/SimpleConfig.java scanned file 1.2 KB SimpleConfig.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ValueToKey.java scanned file 5.2 KB ValueToKey.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/resources/META-INF/services/org.apache.kafka.connect.transforms.predicates.Predicate scanned file 981 bytes org.apache.kafka.connect.transforms.predicates.Predicate .Predicate text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/resources/META-INF/services/org.apache.kafka.connect.transforms.Transformation scanned file 2.1 KB org.apache.kafka.connect.transforms.Transformation .Transformation text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/CastTest.java scanned file 27.7 KB CastTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/DropHeadersTest.java scanned file 4.7 KB DropHeadersTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/ExtractFieldTest.java scanned file 9.9 KB ExtractFieldTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/field/FieldPathNotationTest.java scanned file 6.2 KB FieldPathNotationTest.java .java Java text/x-c++ apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/field/FieldSyntaxVersionTest.java scanned file 3.2 KB FieldSyntaxVersionTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/field/SingleFieldPathTest.java scanned file 4.5 KB SingleFieldPathTest.java .java Java text/x-c++ apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/FlattenTest.java scanned file 16.8 KB FlattenTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/HeaderFromTest.java scanned file 19.6 KB HeaderFromTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/HoistFieldTest.java scanned file 3.1 KB HoistFieldTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/InsertFieldTest.java scanned file 11.3 KB InsertFieldTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/InsertHeaderTest.java scanned file 4.9 KB InsertHeaderTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/MaskFieldTest.java scanned file 12.4 KB MaskFieldTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/predicates/HasHeaderKeyTest.java scanned file 4.0 KB HasHeaderKeyTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/predicates/TopicNameMatchesTest.java scanned file 3.7 KB TopicNameMatchesTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/RegexRouterTest.java scanned file 2.5 KB RegexRouterTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/ReplaceFieldTest.java scanned file 7.4 KB ReplaceFieldTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/SetSchemaMetadataTest.java scanned file 8.7 KB SetSchemaMetadataTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/TimestampConverterTest.java scanned file 34.0 KB TimestampConverterTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/TimestampRouterTest.java scanned file 1.9 KB TimestampRouterTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/util/NonEmptyListValidatorTest.java scanned file 1.5 KB NonEmptyListValidatorTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/ValueToKeyTest.java scanned file 5.2 KB ValueToKeyTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorEvent.java scanned file 1.4 KB CoordinatorEvent.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorEventProcessor.java scanned file 1.6 KB CoordinatorEventProcessor.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorExecutorImpl.java scanned file 4.9 KB CoordinatorExecutorImpl.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorExecutor.java scanned file 2.6 KB CoordinatorExecutor.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorLoaderImpl.java scanned file 15.9 KB CoordinatorLoaderImpl.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorLoader.java scanned file 1.8 KB CoordinatorLoader.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorMetadataDelta.java scanned file 2.1 KB CoordinatorMetadataDelta.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorMetadataImage.java scanned file 2.7 KB CoordinatorMetadataImage.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorMetrics.java scanned file 2.9 KB CoordinatorMetrics.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorMetricsShard.java scanned file 1.9 KB CoordinatorMetricsShard.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorOperationExceptionHelper.java scanned file 3.6 KB CoordinatorOperationExceptionHelper.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorPlayback.java scanned file 2.5 KB CoordinatorPlayback.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRecord.java scanned file 3.2 KB CoordinatorRecord.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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