1,759 results
« Page 2 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/integration-tests/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java scanned file 47.2 KB RestoreIntegrationTest.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/RocksDBMetricsIntegrationTest.java scanned file 16.6 KB RocksDBMetricsIntegrationTest.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/SelfJoinUpgradeIntegrationTest.java scanned file 10.8 KB SelfJoinUpgradeIntegrationTest.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/SlidingWindowedKStreamIntegrationTest.java scanned file 23.2 KB SlidingWindowedKStreamIntegrationTest.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/SmokeTestDriverIntegrationTest.java scanned file 9.1 KB SmokeTestDriverIntegrationTest.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/StandbyTaskCreationIntegrationTest.java scanned file 8.6 KB StandbyTaskCreationIntegrationTest.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/StandbyTaskEOSIntegrationTest.java scanned file 15.7 KB StandbyTaskEOSIntegrationTest.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/StandbyTaskEOSMultiRebalanceIntegrationTest.java scanned file 13.7 KB StandbyTaskEOSMultiRebalanceIntegrationTest.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/StateDirectoryIntegrationTest.java scanned file 11.8 KB StateDirectoryIntegrationTest.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/StateUpdaterFailureIntegrationTest.java scanned file 7.5 KB StateUpdaterFailureIntegrationTest.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/StoreQueryIntegrationTest.java scanned file 32.7 KB StoreQueryIntegrationTest.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/StoreQuerySuite.java scanned file 2.0 KB StoreQuerySuite.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/StoreUpgradeIntegrationTest.java scanned file 46.9 KB StoreUpgradeIntegrationTest.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/StreamStreamJoinIntegrationTest.java scanned file 24.5 KB StreamStreamJoinIntegrationTest.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/StreamsUncaughtExceptionHandlerIntegrationTest.java scanned file 17.7 KB StreamsUncaughtExceptionHandlerIntegrationTest.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/StreamsUpgradeTestIntegrationTest.java scanned file 5.5 KB StreamsUpgradeTestIntegrationTest.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/StreamTableJoinIntegrationTest.java scanned file 8.0 KB StreamTableJoinIntegrationTest.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/StreamTableJoinTopologyOptimizationIntegrationTest.java scanned file 10.7 KB StreamTableJoinTopologyOptimizationIntegrationTest.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/StreamTableJoinWithGraceIntegrationTest.java scanned file 5.4 KB StreamTableJoinWithGraceIntegrationTest.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/SuppressionDurabilityIntegrationTest.java scanned file 13.7 KB SuppressionDurabilityIntegrationTest.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/SuppressionIntegrationTest.java scanned file 23.8 KB SuppressionIntegrationTest.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/SwallowUnknownTopicErrorIntegrationTest.java scanned file 7.6 KB SwallowUnknownTopicErrorIntegrationTest.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/TableTableJoinIntegrationTest.java scanned file 58.3 KB TableTableJoinIntegrationTest.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/TaskAssignorIntegrationTest.java scanned file 8.5 KB TaskAssignorIntegrationTest.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/TaskMetadataIntegrationTest.java scanned file 8.6 KB TaskMetadataIntegrationTest.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/TestingMetricsInterceptingAdminClient.java scanned file 24.8 KB TestingMetricsInterceptingAdminClient.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/TestTaskAssignor.java scanned file 1.9 KB TestTaskAssignor.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/TimeWindowedKStreamIntegrationTest.java scanned file 23.7 KB TimeWindowedKStreamIntegrationTest.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/utils scanned directory utils
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/utils/CompositeStateListener.java scanned file 1.9 KB CompositeStateListener.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/utils/EmbeddedKafkaCluster.java scanned file 23.9 KB EmbeddedKafkaCluster.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/utils/IntegrationTestUtils.java scanned file 67.8 KB IntegrationTestUtils.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/VersionedKeyValueStoreIntegrationTest.java scanned file 36.5 KB VersionedKeyValueStoreIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/resources scanned directory resources
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/resources/log4j2.yaml scanned file 1.8 KB log4j2.yaml .yaml text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/scala scanned directory scala
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/scala/org scanned directory org
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/scala/org/apache scanned directory apache
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/scala/org/apache/kafka scanned directory kafka
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/scala/org/apache/kafka/streams scanned directory streams
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/scala/org/apache/kafka/streams/integration scanned directory integration
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/scala/org/apache/kafka/streams/integration/StreamToTableJoinScalaIntegrationTestImplicitSerdes.scala scanned file 7.5 KB StreamToTableJoinScalaIntegrationTestImplicitSerdes.scala .scala Scala text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/scala/org/apache/kafka/streams/integration/utils scanned directory utils
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/scala/org/apache/kafka/streams/integration/utils/StreamToTableJoinScalaIntegrationTestBase.scala scanned file 5.1 KB StreamToTableJoinScalaIntegrationTestBase.scala .scala Scala text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/scala/org/apache/kafka/streams/integration/utils/StreamToTableJoinTestData.scala scanned file 2.2 KB StreamToTableJoinTestData.scala .scala Scala text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/scala/org/apache/kafka/streams/integration/WordCountTest.scala scanned file 9.1 KB WordCountTest.scala .scala Scala text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart scanned directory quickstart
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java scanned directory java
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/pom.xml application-package file 1.4 KB pom.xml .xml text/plain
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src scanned directory src
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/main scanned directory main
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/main/resources scanned directory resources
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/main/resources/archetype-resources scanned directory archetype-resources
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/main/resources/archetype-resources/pom.xml application-package file 4.9 KB pom.xml .xml text/plain
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/main/resources/archetype-resources/src scanned directory src
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/main/resources/archetype-resources/src/main scanned directory main
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/main/resources/archetype-resources/src/main/java scanned directory java
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/LineSplit.java scanned file 2.9 KB LineSplit.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/Pipe.java scanned file 2.6 KB Pipe.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/WordCount.java scanned file 3.5 KB WordCount.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/main/resources/archetype-resources/src/main/resources scanned directory resources
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/main/resources/archetype-resources/src/main/resources/log4j2.yaml scanned file 1.1 KB log4j2.yaml .yaml text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/main/resources/META-INF scanned directory META-INF
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/main/resources/META-INF/maven scanned directory maven
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/main/resources/META-INF/maven/archetype-metadata.xml scanned file 1.5 KB archetype-metadata.xml .xml text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/test scanned directory test
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/test/resources scanned directory resources
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/test/resources/projects scanned directory projects
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/test/resources/projects/basic scanned directory basic
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/test/resources/projects/basic/archetype.properties scanned file 886 bytes archetype.properties .properties text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/test/resources/projects/basic/goal.txt scanned file 7 bytes goal.txt .txt text/plain
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/quickstart/pom.xml application-package file 4.4 KB pom.xml .xml text/plain
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src scanned directory src
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main scanned directory main
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java scanned directory java
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org scanned directory org
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache scanned directory apache
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka scanned directory kafka
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams scanned directory streams
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/AutoOffsetReset.java scanned file 3.8 KB AutoOffsetReset.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/ClientInstanceIds.java scanned file 1.8 KB ClientInstanceIds.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/CloseOptions.java scanned file 3.9 KB CloseOptions.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/errors scanned directory errors
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/errors/BrokerNotFoundException.java scanned file 1.5 KB BrokerNotFoundException.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/errors/DefaultProductionExceptionHandler.java scanned file 2.7 KB DefaultProductionExceptionHandler.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/errors/DeserializationExceptionHandler.java scanned file 9.6 KB DeserializationExceptionHandler.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/errors/ErrorHandlerContext.java scanned file 8.6 KB ErrorHandlerContext.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/errors/internals scanned directory internals
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/errors/internals/DefaultErrorHandlerContext.java scanned file 3.8 KB DefaultErrorHandlerContext.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/errors/internals/ExceptionHandlerUtils.java scanned file 5.8 KB ExceptionHandlerUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/errors/internals/FailedProcessingException.java scanned file 1.9 KB FailedProcessingException.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/errors/InternalTopicsAlreadySetupException.java scanned file 1.0 KB InternalTopicsAlreadySetupException.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/errors/InvalidStateStoreException.java scanned file 1.5 KB InvalidStateStoreException.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/errors/InvalidStateStorePartitionException.java scanned file 1.6 KB InvalidStateStorePartitionException.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/errors/LockException.java scanned file 1.4 KB LockException.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/errors/LogAndContinueExceptionHandler.java scanned file 2.4 KB LogAndContinueExceptionHandler.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/errors/LogAndContinueProcessingExceptionHandler.java scanned file 2.5 KB LogAndContinueProcessingExceptionHandler.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/errors/LogAndFailExceptionHandler.java scanned file 2.4 KB LogAndFailExceptionHandler.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/errors/LogAndFailProcessingExceptionHandler.java scanned file 2.5 KB LogAndFailProcessingExceptionHandler.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/errors/MisconfiguredInternalTopicException.java scanned file 1.0 KB MisconfiguredInternalTopicException.java .java Java text/plain apache-2.0