[yaml] package kafka_clients 3.1.2 in Kafka Provider jar #17001
GitHub Actions / Test Results
failed
Oct 2, 2024 in 0s
1 fail, 1 skipped, 147 pass in 59m 13s
37 files 37 suites 59m 13s ⏱️
149 tests 147 ✅ 1 💤 1 ❌
709 runs 697 ✅ 11 💤 1 ❌
Results for commit 0f0f23b.
Annotations
Check warning on line 0 in org.apache.beam.sdk.io.kafka.KafkaIOTest
github-actions / Test Results
1 out of 11 runs failed: testUnboundedSourceWithWrongTopic (org.apache.beam.sdk.io.kafka.KafkaIOTest)
sdks/java/io/kafka/build/test-results/kafkaVersion312Test/TEST-org.apache.beam.sdk.io.kafka.KafkaIOTest.xml [took 0s]
Raw output
java.lang.AssertionError:
Expected: (an instance of org.apache.beam.sdk.Pipeline$PipelineExecutionException and exception with cause an instance of java.lang.IllegalStateException and exception with message a string containing "Could not find any partitions info. Please check Kafka configuration and make sure that provided topics exist.")
but: exception with message a string containing "Could not find any partitions info. Please check Kafka configuration and make sure that provided topics exist." message was "java.lang.IllegalStateException: Could not find any partitions. Please check Kafka configuration and topic names"
Stacktrace was: org.apache.beam.sdk.Pipeline$PipelineExecutionException: java.lang.IllegalStateException: Could not find any partitions. Please check Kafka configuration and topic names
at org.apache.beam.runners.direct.DirectRunner$DirectPipelineResult.waitUntilFinish(DirectRunner.java:377)
at org.apache.beam.runners.direct.DirectRunner$DirectPipelineResult.waitUntilFinish(DirectRunner.java:345)
at org.apache.beam.runners.direct.DirectRunner.run(DirectRunner.java:218)
at org.apache.beam.runners.direct.DirectRunner.run(DirectRunner.java:67)
at org.apache.beam.sdk.Pipeline.run(Pipeline.java:325)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:404)
at org.apache.beam.sdk.testing.TestPipeline.run(TestPipeline.java:343)
at org.apache.beam.sdk.io.kafka.KafkaIOTest.testUnboundedSourceWithWrongTopic(KafkaIOTest.java:989)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
at org.junit.rules.ExpectedException$ExpectedExceptionStatement.evaluate(ExpectedException.java:258)
at org.apache.beam.sdk.testing.TestPipeline$1.evaluate(TestPipeline.java:331)
at org.junit.rules.ExpectedException$ExpectedExceptionStatement.evaluate(ExpectedException.java:258)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.runTestClass(JUnitTestClassExecutor.java:112)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:58)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:40)
at org.gradle.api.internal.tasks.testing.junit.AbstractJUnitTestClassProcessor.processTestClass(AbstractJUnitTestClassProcessor.java:60)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:52)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36)
at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:33)
at org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:94)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker$2.run(TestWorker.java:176)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.executeAndMaintainThreadName(TestWorker.java:129)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:100)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:60)
at org.gradle.process.internal.worker.child.ActionExecutionWorker.execute(ActionExecutionWorker.java:56)
at org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:113)
at org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:65)
at worker.org.gradle.process.internal.worker.GradleWorkerMain.run(GradleWorkerMain.java:69)
at worker.org.gradle.process.internal.worker.GradleWorkerMain.main(GradleWorkerMain.java:74)
Caused by: java.lang.IllegalStateException: Could not find any partitions. Please check Kafka configuration and topic names
at org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.base.Preconditions.checkState(Preconditions.java:512)
at org.apache.beam.sdk.io.kafka.KafkaUnboundedSource.split(KafkaUnboundedSource.java:112)
at org.apache.beam.sdk.io.BoundedReadFromUnboundedSource$SplitFn.process(BoundedReadFromUnboundedSource.java:169)
at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:18)
at org.junit.Assert.assertThat(Assert.java:964)
at org.junit.Assert.assertThat(Assert.java:930)
at org.junit.rules.ExpectedException.handleException(ExpectedException.java:271)
at org.junit.rules.ExpectedException.access$000(ExpectedException.java:111)
at org.junit.rules.ExpectedException$ExpectedExceptionStatement.evaluate(ExpectedException.java:260)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.runTestClass(JUnitTestClassExecutor.java:112)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:58)
at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:40)
at org.gradle.api.internal.tasks.testing.junit.AbstractJUnitTestClassProcessor.processTestClass(AbstractJUnitTestClassProcessor.java:60)
at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:52)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36)
at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:33)
at org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:94)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at org.gradle.api.internal.tasks.testing.worker.TestWorker$2.run(TestWorker.java:176)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.executeAndMaintainThreadName(TestWorker.java:129)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:100)
at org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:60)
at org.gradle.process.internal.worker.child.ActionExecutionWorker.execute(ActionExecutionWorker.java:56)
at org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:113)
at org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:65)
at worker.org.gradle.process.internal.worker.GradleWorkerMain.run(GradleWorkerMain.java:69)
at worker.org.gradle.process.internal.worker.GradleWorkerMain.main(GradleWorkerMain.java:74)
Check notice on line 0 in .github
github-actions / Test Results
1 skipped test found
There is 1 skipped test, see "Raw output" for the name of the skipped test.
Raw output
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithoutBoundedWrapper
Check notice on line 0 in .github
github-actions / Test Results
149 tests found
There are 149 tests, see "Raw output" for the full list of tests.
Raw output
org.apache.beam.sdk.io.kafka.ConfluentSchemaRegistryDeserializerProviderTest ‑ testDeserialize
org.apache.beam.sdk.io.kafka.ConfluentSchemaRegistryDeserializerProviderTest ‑ testGetCoder
org.apache.beam.sdk.io.kafka.CustomTimestampPolicyWithLimitedDelayTest ‑ testCustomTimestampPolicyWithLimitedDelay
org.apache.beam.sdk.io.kafka.KafkaCommitOffsetTest ‑ testCommitOffsetDoFn
org.apache.beam.sdk.io.kafka.KafkaCommitOffsetTest ‑ testCommitOffsetError
org.apache.beam.sdk.io.kafka.KafkaCommitOffsetTest ‑ testKafkaOffsetComposite
org.apache.beam.sdk.io.kafka.KafkaCommitOffsetTest ‑ testKafkaOffsetCompositeLegacy
org.apache.beam.sdk.io.kafka.KafkaDlqTest ‑ testKafkaErrorFnFailure
org.apache.beam.sdk.io.kafka.KafkaDlqTest ‑ testKafkaErrorFnSuccess
org.apache.beam.sdk.io.kafka.KafkaIOExternalTest ‑ testConstructKafkaRead
org.apache.beam.sdk.io.kafka.KafkaIOExternalTest ‑ testConstructKafkaReadWithoutMetadata
org.apache.beam.sdk.io.kafka.KafkaIOExternalTest ‑ testConstructKafkaWrite
org.apache.beam.sdk.io.kafka.KafkaIOExternalTest ‑ testKafkaRecordToExternalKafkaRecord
org.apache.beam.sdk.io.kafka.KafkaIOExternalTest ‑ testKafkaRecordToExternalKafkaRecordWithNullKeyAndValue
org.apache.beam.sdk.io.kafka.KafkaIOIT ‑ testKafkaIOExternalRoundtripWithMetadataAndNullKeysAndValues
org.apache.beam.sdk.io.kafka.KafkaIOIT ‑ testKafkaIOReadsAndWritesCorrectlyInBatch
org.apache.beam.sdk.io.kafka.KafkaIOIT ‑ testKafkaIOSDFReadWithErrorHandler
org.apache.beam.sdk.io.kafka.KafkaIOIT ‑ testKafkaIOSDFResumesCorrectly
org.apache.beam.sdk.io.kafka.KafkaIOIT ‑ testKafkaIOWriteWithErrorHandler
org.apache.beam.sdk.io.kafka.KafkaIOIT ‑ testKafkaViaManagedSchemaTransformAvro
org.apache.beam.sdk.io.kafka.KafkaIOIT ‑ testKafkaViaManagedSchemaTransformJson
org.apache.beam.sdk.io.kafka.KafkaIOIT ‑ testKafkaWithDelayedStopReadingFunction
org.apache.beam.sdk.io.kafka.KafkaIOIT ‑ testKafkaWithDynamicPartitions
org.apache.beam.sdk.io.kafka.KafkaIOIT ‑ testKafkaWithStopReadingFunction
org.apache.beam.sdk.io.kafka.KafkaIOIT ‑ testWatermarkUpdateWithSparseMessages
org.apache.beam.sdk.io.kafka.KafkaIOReadImplementationCompatibilityTest ‑ testKafkaIOReadPropertiesEnumValuePresence
org.apache.beam.sdk.io.kafka.KafkaIOReadImplementationCompatibilityTest ‑ testPrimitiveKafkaIOReadPropertiesDefaultValueExistence
org.apache.beam.sdk.io.kafka.KafkaIOReadImplementationCompatibilityTest ‑ testReadTransformCreationWithBothImplementationBoundProperties
org.apache.beam.sdk.io.kafka.KafkaIOReadImplementationCompatibilityTest ‑ testReadTransformCreationWithLegacyImplementationBoundProperty
org.apache.beam.sdk.io.kafka.KafkaIOReadImplementationCompatibilityTest ‑ testReadTransformCreationWithSdfImplementationBoundProperty
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ noWarningsWithNoAllowDuplicatesAndCommitOffsets
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testDeserializationWithHeaders
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testDisableRedistributeKafkaOffsetLegacy
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testExactlyOnceSink
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testExactlyOnceSinkWithSendException
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testKafkaWriteHeaders
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testNumKeysIgnoredWithRedistributeNotEnabled
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testReadAvroGenericRecordsWithConfluentSchemaRegistry
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testReadAvroSpecificRecordsWithConfluentSchemaRegistry
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testRecordsSink
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testResolveDefaultApiTimeout
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testRiskyConfigurationWarnsProperly
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSink
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSinkDisplayData
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSinkMetrics
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSinkProducerRecordsWithCustomPartition
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSinkProducerRecordsWithCustomTS
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSinkToMultipleTopics
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSinkWithSendErrors
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSinkWithSerializationErrors
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSourceDisplayData
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSourceWithExplicitPartitionsDisplayData
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testSourceWithPatternDisplayData
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedReaderLogsCommitFailure
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSource
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceCheckpointMark
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceCheckpointMarkWithEmptyPartitions
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceCreateTimestamps
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceCustomTimestamps
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceLogAppendTimestamps
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceMetrics
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceRawSizeMetric
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceSplits
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceStartReadTime
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceStartReadTimeException
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceTimestamps
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithExceptionInKafkaFetch
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithExplicitPartitions
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithPartiallyMatchedPattern
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithPattern
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithSingleTopic
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithUnmatchedPattern
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithWrongTopic
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnboundedSourceWithoutBoundedWrapper
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testUnreachableKafkaBrokers
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testValuesSink
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testWithInvalidConsumerPollingTimeout
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ testWithValidConsumerPollingTimeout
org.apache.beam.sdk.io.kafka.KafkaIOTest ‑ warningsWithAllowDuplicatesEnabledAndCommitOffsets
org.apache.beam.sdk.io.kafka.KafkaIOUtilsTest ‑ testOffsetConsumerConfigOverrides
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testBuildTransformWithAvroSchema
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testBuildTransformWithJsonSchema
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testBuildTransformWithManaged
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testBuildTransformWithProtoFormat
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testBuildTransformWithProtoFormatWrongMessageName
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testBuildTransformWithProtoSchemaFormat
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testBuildTransformWithRawFormat
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testBuildTransformWithoutProtoSchemaFormat
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testFindTransformAndMakeItWork
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testManagedMappings
org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProviderTest ‑ testValidConfigurations
org.apache.beam.sdk.io.kafka.KafkaRecordCoderTest ‑ testCoderIsSerializableWithWellKnownCoderType
org.apache.beam.sdk.io.kafka.KafkaRecordCoderTest ‑ testKafkaRecordSerializableWithHeaders
org.apache.beam.sdk.io.kafka.KafkaRecordCoderTest ‑ testKafkaRecordSerializableWithNullValueHeader
org.apache.beam.sdk.io.kafka.KafkaRecordCoderTest ‑ testKafkaRecordSerializableWithoutHeaders
org.apache.beam.sdk.io.kafka.KafkaSchemaTransformTranslationTest ‑ testReCreateReadTransformFromRow
org.apache.beam.sdk.io.kafka.KafkaSchemaTransformTranslationTest ‑ testReadTransformProtoTranslation
org.apache.beam.sdk.io.kafka.KafkaSchemaTransformTranslationTest ‑ testRecreateWriteTransformFromRow
org.apache.beam.sdk.io.kafka.KafkaSchemaTransformTranslationTest ‑ testWriteTransformProtoTranslation
org.apache.beam.sdk.io.kafka.KafkaWriteSchemaTransformProviderTest ‑ testBuildTransformWithManaged
org.apache.beam.sdk.io.kafka.KafkaWriteSchemaTransformProviderTest ‑ testKafkaErrorFnProtoSuccess
org.apache.beam.sdk.io.kafka.KafkaWriteSchemaTransformProviderTest ‑ testKafkaErrorFnRawSuccess
org.apache.beam.sdk.io.kafka.KafkaWriteSchemaTransformProviderTest ‑ testKafkaErrorFnSuccess
org.apache.beam.sdk.io.kafka.KafkaWriteSchemaTransformProviderTest ‑ testManagedMappings
org.apache.beam.sdk.io.kafka.LocalDeserializerProviderTest ‑ testInferKeyCoder
org.apache.beam.sdk.io.kafka.LocalDeserializerProviderTest ‑ testInferKeyCoderFailure
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testCoderIsSerializableWithWellKnownCoderType
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testProducerRecordSerializableWithHeaders
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testProducerRecordSerializableWithPartition
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testProducerRecordSerializableWithTimestamp
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testProducerRecordSerializableWithoutHeaders
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testProducerRecordSerializableWithoutPartition
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testProducerRecordSerializableWithoutTimestamp
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testProducerRecordStructuralValueWithHeadersApi
org.apache.beam.sdk.io.kafka.ProducerRecordCoderTest ‑ testProducerRecordStructuralValueWithoutHeadersApi
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testBounded
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testConstructorWithPollTimeout
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testInitialRestrictionWhenHasStartOffset
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testInitialRestrictionWhenHasStartTime
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testInitialRestrictionWhenHasStopOffset
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testInitialRestrictionWhenHasStopTime
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testInitialRestrictionWithConsumerPosition
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testInitialRestrictionWithException
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testProcessElement
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testProcessElementWhenTopicPartitionIsRemoved
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testProcessElementWhenTopicPartitionIsStopped
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testProcessElementWithDeserializationExceptionDefaultRecordHandler
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testProcessElementWithDeserializationExceptionRecordingRecordHandler
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testProcessElementWithEarlierOffset
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testProcessElementWithEmptyPoll
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testProcessElementWithException
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testRawSizeMetric
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testSDFCommitOffsetEnabled
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testSDFCommitOffsetNotEnabled
org.apache.beam.sdk.io.kafka.ReadFromKafkaDoFnTest ‑ testUnbounded
org.apache.beam.sdk.io.kafka.TopicPartitionCoderTest ‑ testEncodeDecodeRoundTrip
org.apache.beam.sdk.io.kafka.TopicPartitionCoderTest ‑ testToString
org.apache.beam.sdk.io.kafka.WatchForKafkaTopicPartitionsTest ‑ testGetAllTopicPartitions
org.apache.beam.sdk.io.kafka.WatchForKafkaTopicPartitionsTest ‑ testGetAllTopicPartitionsWithGivenPattern
org.apache.beam.sdk.io.kafka.WatchForKafkaTopicPartitionsTest ‑ testGetAllTopicPartitionsWithGivenTopics
org.apache.beam.sdk.io.kafka.WatchForKafkaTopicPartitionsTest ‑ testPartitionGrowth
org.apache.beam.sdk.io.kafka.WatchForKafkaTopicPartitionsTest ‑ testPartitionSingle
org.apache.beam.sdk.io.kafka.upgrade.KafkaIOTranslationTest ‑ testReCreateReadTransformFromRow
org.apache.beam.sdk.io.kafka.upgrade.KafkaIOTranslationTest ‑ testReCreateReadTransformWithTopics
org.apache.beam.sdk.io.kafka.upgrade.KafkaIOTranslationTest ‑ testReCreateWriteTransformFromRow
org.apache.beam.sdk.io.kafka.upgrade.KafkaIOTranslationTest ‑ testReadTransformRowIncludesAllFields
org.apache.beam.sdk.io.kafka.upgrade.KafkaIOTranslationTest ‑ testReadTransformURNDiscovery
org.apache.beam.sdk.io.kafka.upgrade.KafkaIOTranslationTest ‑ testWriteTransformRowIncludesAllFields
org.apache.beam.sdk.io.kafka.upgrade.KafkaIOTranslationTest ‑ testWriteTransformURNDiscovery
Loading