1,759 results
« Page 1 of 18 »
Search: kafka_neu-1778570057504.zip-extract/kaf…
View the resource tree
Packages
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams scanned directory streams
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples scanned directory examples
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src scanned directory src
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main scanned directory main
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java scanned directory java
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org scanned directory org
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org/apache scanned directory apache
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org/apache/kafka scanned directory kafka
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org/apache/kafka/streams scanned directory streams
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org/apache/kafka/streams/examples scanned directory examples
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview scanned directory pageview
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/JsonTimestampExtractor.java scanned file 1.9 KB JsonTimestampExtractor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewTypedDemo.java scanned file 10.2 KB PageViewTypedDemo.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewUntypedDemo.java scanned file 7.2 KB PageViewUntypedDemo.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org/apache/kafka/streams/examples/pipe scanned directory pipe
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org/apache/kafka/streams/examples/pipe/PipeDemo.java scanned file 3.1 KB PipeDemo.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org/apache/kafka/streams/examples/temperature scanned directory temperature
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org/apache/kafka/streams/examples/temperature/TemperatureDemo.java scanned file 5.8 KB TemperatureDemo.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount scanned directory wordcount
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java scanned file 5.0 KB WordCountDemo.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorDemo.java scanned file 6.4 KB WordCountProcessorDemo.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerDemo.java scanned file 7.3 KB WordCountTransformerDemo.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/test scanned directory test
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/test/java scanned directory java
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/test/java/org scanned directory org
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/test/java/org/apache scanned directory apache
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/test/java/org/apache/kafka scanned directory kafka
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/test/java/org/apache/kafka/streams scanned directory streams
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/test/java/org/apache/kafka/streams/examples scanned directory examples
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/test/java/org/apache/kafka/streams/examples/docs scanned directory docs
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/test/java/org/apache/kafka/streams/examples/docs/DeveloperGuideTesting.java scanned file 7.4 KB DeveloperGuideTesting.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount scanned directory wordcount
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount/WordCountDemoTest.java scanned file 4.9 KB WordCountDemoTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorTest.java scanned file 3.3 KB WordCountProcessorTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerTest.java scanned file 4.4 KB WordCountTransformerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/.gitignore scanned file 6 bytes .gitignore text/plain
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests scanned directory integration-tests
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src scanned directory src
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test scanned directory test
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java scanned directory java
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org scanned directory org
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache scanned directory apache
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka scanned directory kafka
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams scanned directory streams
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration scanned directory integration
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/AbstractJoinIntegrationTest.java scanned file 14.2 KB AbstractJoinIntegrationTest.java .java Java text/x-Algol68 apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/AdjustStreamThreadCountTest.java scanned file 23.9 KB AdjustStreamThreadCountTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/AtLeastOnceDeliveryMessageLossIntegrationTest.java scanned file 10.7 KB AtLeastOnceDeliveryMessageLossIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/ConsistencyVectorIntegrationTest.java scanned file 9.3 KB ConsistencyVectorIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/DeadLetterQueueIntegrationTest.java scanned file 25.8 KB DeadLetterQueueIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/EmitOnChangeIntegrationTest.java scanned file 6.9 KB EmitOnChangeIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java scanned file 70.5 KB EosIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/EOSUncleanShutdownIntegrationTest.java scanned file 7.8 KB EOSUncleanShutdownIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/FineGrainedAutoResetIntegrationTest.java scanned file 21.0 KB FineGrainedAutoResetIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/ForeignKeyJoinSuite.java scanned file 2.3 KB ForeignKeyJoinSuite.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/GlobalKTableEOSIntegrationTest.java scanned file 21.0 KB GlobalKTableEOSIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/GlobalKTableIntegrationTest.java scanned file 17.9 KB GlobalKTableIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/GlobalStateReprocessTest.java scanned file 7.7 KB GlobalStateReprocessTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/GlobalThreadShutDownOrderTest.java scanned file 8.9 KB GlobalThreadShutDownOrderTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/HandlingSourceTopicDeletionIntegrationTest.java scanned file 5.8 KB HandlingSourceTopicDeletionIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/HighAvailabilityTaskAssignorIntegrationTest.java scanned file 16.7 KB HighAvailabilityTaskAssignorIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/InternalTopicIntegrationTest.java scanned file 12.4 KB InternalTopicIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/IQv2EndpointToPartitionsIntegrationTest.java scanned file 16.1 KB IQv2EndpointToPartitionsIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/IQv2IntegrationTest.java scanned file 21.0 KB IQv2IntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java scanned file 82.7 KB IQv2StoreIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/IQv2VersionedStoreIntegrationTest.java scanned file 22.2 KB IQv2VersionedStoreIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/JoinGracePeriodDurabilityIntegrationTest.java scanned file 10.5 KB JoinGracePeriodDurabilityIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/JoinStoreIntegrationTest.java scanned file 8.0 KB JoinStoreIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/JoinWithIncompleteMetadataIntegrationTest.java scanned file 5.5 KB JoinWithIncompleteMetadataIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KafkaStreamsCloseOptionsIntegrationTest.java scanned file 8.3 KB KafkaStreamsCloseOptionsIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KafkaStreamsTelemetryIntegrationTest.java scanned file 37.2 KB KafkaStreamsTelemetryIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KafkaStreamsWrapper.java scanned file 2.4 KB KafkaStreamsWrapper.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationDedupIntegrationTest.java scanned file 11.7 KB KStreamAggregationDedupIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationIntegrationTest.java scanned file 60.9 KB KStreamAggregationIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KStreamKStreamIntegrationTest.java scanned file 8.4 KB KStreamKStreamIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KStreamRepartitionIntegrationTest.java scanned file 35.8 KB KStreamRepartitionIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableEfficientRangeQueryTest.java scanned file 9.9 KB KTableEfficientRangeQueryTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest.java scanned file 16.8 KB KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyInnerJoinMultiIntegrationTest.java scanned file 13.7 KB KTableKTableForeignKeyInnerJoinMultiIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinDistributedTest.java scanned file 10.3 KB KTableKTableForeignKeyJoinDistributedTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinIntegrationTest.java scanned file 57.9 KB KTableKTableForeignKeyJoinIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinMaterializationIntegrationTest.java scanned file 7.5 KB KTableKTableForeignKeyJoinMaterializationIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableSourceTopicRestartIntegrationTest.java scanned file 10.5 KB KTableSourceTopicRestartIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/LagFetchIntegrationTest.java scanned file 17.9 KB LagFetchIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/MetricsIntegrationTest.java scanned file 43.5 KB MetricsIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/MetricsReporterIntegrationTest.java scanned file 5.0 KB MetricsReporterIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/NamedTopologyIntegrationTest.java scanned file 42.2 KB NamedTopologyIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/OptimizedKTableIntegrationTest.java scanned file 10.3 KB OptimizedKTableIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/PauseResumeIntegrationTest.java scanned file 18.5 KB PauseResumeIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/PositionRestartIntegrationTest.java scanned file 27.0 KB PositionRestartIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/ProcessingExceptionHandlerIntegrationTest.java scanned file 32.5 KB ProcessingExceptionHandlerIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/PurgeRepartitionTopicIntegrationTest.java scanned file 9.5 KB PurgeRepartitionTopicIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java scanned file 58.1 KB QueryableStateIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RangeQueryIntegrationTest.java scanned file 12.0 KB RangeQueryIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RebalanceIntegrationTest.java scanned file 9.9 KB RebalanceIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RebalanceProtocolMigrationIntegrationTest.java scanned file 8.9 KB RebalanceProtocolMigrationIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RebalanceTaskClosureIntegrationTest.java scanned file 11.9 KB RebalanceTaskClosureIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RegexSourceIntegrationTest.java scanned file 26.3 KB RegexSourceIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RelaxedNullKeyRequirementJoinTest.java scanned file 5.6 KB RelaxedNullKeyRequirementJoinTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/ResetPartitionTimeIntegrationTest.java scanned file 8.3 KB ResetPartitionTimeIntegrationTest.java .java Java text/x-Algol68 apache-2.0