See <https://ci-builds.apache.org/job/Kafka/job/kafka/job/3.3/89/display/redirect>
Changes: ------------------------------------------ [...truncated 500510 lines...] [2022-09-27T08:48:30.987Z] [2022-09-27T08:48:30.987Z] Exception: java.lang.AssertionError thrown from the UncaughtExceptionHandler in thread "appId_StreamsUncaughtExceptionHandlerIntegrationTestnull-cf8843db-d0d6-49e1-a24d-4bc55d8b7b7d-StreamThread-1" [2022-09-27T08:48:30.987Z] [2022-09-27T08:48:30.987Z] org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest > shouldReplaceSingleThread PASSED [2022-09-27T08:48:30.987Z] [2022-09-27T08:48:30.987Z] org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest > shouldShutdownMultipleThreadApplication STARTED [2022-09-27T08:48:39.984Z] [2022-09-27T08:48:39.984Z] org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest > shouldShutdownMultipleThreadApplication PASSED [2022-09-27T08:48:39.984Z] [2022-09-27T08:48:39.984Z] org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest > shouldShutdownClient STARTED [2022-09-27T08:48:40.951Z] [2022-09-27T08:48:40.951Z] org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest > shouldShutdownClient PASSED [2022-09-27T08:48:40.951Z] [2022-09-27T08:48:40.951Z] org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest > shouldShutdownSingleThreadApplication STARTED [2022-09-27T08:48:49.106Z] [2022-09-27T08:48:49.106Z] org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest > shouldShutdownSingleThreadApplication PASSED [2022-09-27T08:48:49.106Z] [2022-09-27T08:48:49.106Z] org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest > shouldEmitSameRecordAfterFailover STARTED [2022-09-27T08:48:52.298Z] [2022-09-27T08:48:52.298Z] org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest > shouldEmitSameRecordAfterFailover PASSED [2022-09-27T08:48:54.206Z] [2022-09-27T08:48:54.206Z] org.apache.kafka.streams.integration.SuppressionDurabilityIntegrationTest > shouldRecoverBufferAfterShutdown[at_least_once] STARTED [2022-09-27T08:49:45.330Z] [2022-09-27T08:49:45.330Z] org.apache.kafka.streams.integration.SuppressionDurabilityIntegrationTest > shouldRecoverBufferAfterShutdown[at_least_once] PASSED [2022-09-27T08:49:45.330Z] [2022-09-27T08:49:45.330Z] org.apache.kafka.streams.integration.SuppressionDurabilityIntegrationTest > shouldRecoverBufferAfterShutdown[exactly_once] STARTED [2022-09-27T08:50:43.668Z] [2022-09-27T08:50:43.668Z] org.apache.kafka.streams.integration.SuppressionDurabilityIntegrationTest > shouldRecoverBufferAfterShutdown[exactly_once] PASSED [2022-09-27T08:50:43.668Z] [2022-09-27T08:50:43.668Z] org.apache.kafka.streams.integration.SuppressionDurabilityIntegrationTest > shouldRecoverBufferAfterShutdown[exactly_once_v2] STARTED [2022-09-27T08:51:34.109Z] [2022-09-27T08:51:34.109Z] org.apache.kafka.streams.integration.SuppressionDurabilityIntegrationTest > shouldRecoverBufferAfterShutdown[exactly_once_v2] PASSED [2022-09-27T08:51:34.109Z] [2022-09-27T08:51:34.109Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testLeftInner[caching enabled = true] STARTED [2022-09-27T08:51:39.035Z] [2022-09-27T08:51:39.035Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testLeftInner[caching enabled = true] PASSED [2022-09-27T08:51:39.035Z] [2022-09-27T08:51:39.035Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testLeftOuter[caching enabled = true] STARTED [2022-09-27T08:51:46.410Z] [2022-09-27T08:51:46.410Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testLeftOuter[caching enabled = true] PASSED [2022-09-27T08:51:46.410Z] [2022-09-27T08:51:46.410Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testLeftLeft[caching enabled = true] STARTED [2022-09-27T08:51:53.766Z] [2022-09-27T08:51:53.766Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testLeftLeft[caching enabled = true] PASSED [2022-09-27T08:51:53.766Z] [2022-09-27T08:51:53.766Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testOuterLeft[caching enabled = true] STARTED [2022-09-27T08:52:01.652Z] [2022-09-27T08:52:01.652Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testOuterLeft[caching enabled = true] PASSED [2022-09-27T08:52:01.652Z] [2022-09-27T08:52:01.652Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testInner[caching enabled = true] STARTED [2022-09-27T08:52:08.296Z] [2022-09-27T08:52:08.296Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testInner[caching enabled = true] PASSED [2022-09-27T08:52:08.296Z] [2022-09-27T08:52:08.296Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testOuter[caching enabled = true] STARTED [2022-09-27T08:52:15.456Z] [2022-09-27T08:52:15.456Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testOuter[caching enabled = true] PASSED [2022-09-27T08:52:15.456Z] [2022-09-27T08:52:15.456Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testLeft[caching enabled = true] STARTED [2022-09-27T08:52:22.423Z] [2022-09-27T08:52:22.423Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testLeft[caching enabled = true] PASSED [2022-09-27T08:52:22.423Z] [2022-09-27T08:52:22.423Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testInnerInner[caching enabled = true] STARTED [2022-09-27T08:52:28.922Z] [2022-09-27T08:52:28.922Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testInnerInner[caching enabled = true] PASSED [2022-09-27T08:52:28.922Z] [2022-09-27T08:52:28.922Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testInnerOuter[caching enabled = true] STARTED [2022-09-27T08:52:36.317Z] [2022-09-27T08:52:36.317Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testInnerOuter[caching enabled = true] PASSED [2022-09-27T08:52:36.317Z] [2022-09-27T08:52:36.317Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testInnerLeft[caching enabled = true] STARTED [2022-09-27T08:52:43.982Z] [2022-09-27T08:52:43.982Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testInnerLeft[caching enabled = true] PASSED [2022-09-27T08:52:43.982Z] [2022-09-27T08:52:43.982Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testOuterInner[caching enabled = true] STARTED [2022-09-27T08:52:50.317Z] [2022-09-27T08:52:50.317Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testOuterInner[caching enabled = true] PASSED [2022-09-27T08:52:50.317Z] [2022-09-27T08:52:50.317Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testOuterOuter[caching enabled = true] STARTED [2022-09-27T08:52:57.497Z] [2022-09-27T08:52:57.497Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testOuterOuter[caching enabled = true] PASSED [2022-09-27T08:52:57.497Z] [2022-09-27T08:52:57.497Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testLeftInner[caching enabled = false] STARTED [2022-09-27T08:53:06.631Z] [2022-09-27T08:53:06.631Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testLeftInner[caching enabled = false] PASSED [2022-09-27T08:53:06.631Z] [2022-09-27T08:53:06.631Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testLeftOuter[caching enabled = false] STARTED [2022-09-27T08:53:12.647Z] [2022-09-27T08:53:12.647Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testLeftOuter[caching enabled = false] PASSED [2022-09-27T08:53:12.647Z] [2022-09-27T08:53:12.647Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testLeftLeft[caching enabled = false] STARTED [2022-09-27T08:53:19.913Z] [2022-09-27T08:53:19.913Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testLeftLeft[caching enabled = false] PASSED [2022-09-27T08:53:19.913Z] [2022-09-27T08:53:19.913Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testOuterLeft[caching enabled = false] STARTED [2022-09-27T08:53:27.714Z] [2022-09-27T08:53:27.714Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testOuterLeft[caching enabled = false] PASSED [2022-09-27T08:53:27.714Z] [2022-09-27T08:53:27.714Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testInner[caching enabled = false] STARTED [2022-09-27T08:53:34.157Z] [2022-09-27T08:53:34.157Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testInner[caching enabled = false] PASSED [2022-09-27T08:53:34.157Z] [2022-09-27T08:53:34.157Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testOuter[caching enabled = false] STARTED [2022-09-27T08:53:42.387Z] [2022-09-27T08:53:42.387Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testOuter[caching enabled = false] PASSED [2022-09-27T08:53:42.387Z] [2022-09-27T08:53:42.387Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testLeft[caching enabled = false] STARTED [2022-09-27T08:53:48.959Z] [2022-09-27T08:53:48.959Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testLeft[caching enabled = false] PASSED [2022-09-27T08:53:48.959Z] [2022-09-27T08:53:48.959Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testInnerInner[caching enabled = false] STARTED [2022-09-27T08:53:55.040Z] [2022-09-27T08:53:55.040Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testInnerInner[caching enabled = false] PASSED [2022-09-27T08:53:55.040Z] [2022-09-27T08:53:55.040Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testInnerOuter[caching enabled = false] STARTED [2022-09-27T08:54:02.957Z] [2022-09-27T08:54:02.957Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testInnerOuter[caching enabled = false] PASSED [2022-09-27T08:54:02.957Z] [2022-09-27T08:54:02.957Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testInnerLeft[caching enabled = false] STARTED [2022-09-27T08:54:10.342Z] [2022-09-27T08:54:10.342Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testInnerLeft[caching enabled = false] PASSED [2022-09-27T08:54:10.342Z] [2022-09-27T08:54:10.342Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testOuterInner[caching enabled = false] STARTED [2022-09-27T08:54:16.472Z] [2022-09-27T08:54:16.472Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testOuterInner[caching enabled = false] PASSED [2022-09-27T08:54:16.472Z] [2022-09-27T08:54:16.472Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testOuterOuter[caching enabled = false] STARTED [2022-09-27T08:54:23.966Z] [2022-09-27T08:54:23.966Z] org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > testOuterOuter[caching enabled = false] PASSED [2022-09-27T08:54:23.966Z] [2022-09-27T08:54:23.966Z] org.apache.kafka.streams.integration.TaskMetadataIntegrationTest > shouldReportCorrectEndOffsetInformation STARTED [2022-09-27T08:54:24.916Z] [2022-09-27T08:54:24.916Z] org.apache.kafka.streams.integration.TaskMetadataIntegrationTest > shouldReportCorrectEndOffsetInformation PASSED [2022-09-27T08:54:24.916Z] [2022-09-27T08:54:24.916Z] org.apache.kafka.streams.integration.TaskMetadataIntegrationTest > shouldReportCorrectCommittedOffsetInformation STARTED [2022-09-27T08:54:26.943Z] [2022-09-27T08:54:26.943Z] org.apache.kafka.streams.integration.TaskMetadataIntegrationTest > shouldReportCorrectCommittedOffsetInformation PASSED [2022-09-27T08:54:27.893Z] [2022-09-27T08:54:27.893Z] org.apache.kafka.streams.processor.internals.HandlingSourceTopicDeletionIntegrationTest > shouldThrowErrorAfterSourceTopicDeleted STARTED [2022-09-27T08:54:34.189Z] [2022-09-27T08:54:34.189Z] org.apache.kafka.streams.processor.internals.HandlingSourceTopicDeletionIntegrationTest > shouldThrowErrorAfterSourceTopicDeleted PASSED [2022-09-27T08:54:36.832Z] [2022-09-27T08:54:36.832Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > testHighAvailabilityTaskAssignorLargeNumConsumers STARTED [2022-09-27T08:54:57.140Z] [2022-09-27T08:54:57.140Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > testHighAvailabilityTaskAssignorLargeNumConsumers PASSED [2022-09-27T08:54:57.140Z] [2022-09-27T08:54:57.140Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > testHighAvailabilityTaskAssignorLargePartitionCount STARTED [2022-09-27T08:54:58.217Z] [2022-09-27T08:54:58.217Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > testHighAvailabilityTaskAssignorLargePartitionCount PASSED [2022-09-27T08:54:58.217Z] [2022-09-27T08:54:58.217Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > testHighAvailabilityTaskAssignorManyThreadsPerClient STARTED [2022-09-27T08:54:58.217Z] [2022-09-27T08:54:58.217Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > testHighAvailabilityTaskAssignorManyThreadsPerClient PASSED [2022-09-27T08:54:58.217Z] [2022-09-27T08:54:58.217Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > testStickyTaskAssignorManyStandbys STARTED [2022-09-27T08:55:05.614Z] [2022-09-27T08:55:05.615Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > testStickyTaskAssignorManyStandbys PASSED [2022-09-27T08:55:05.615Z] [2022-09-27T08:55:05.615Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > testStickyTaskAssignorManyThreadsPerClient STARTED [2022-09-27T08:55:06.557Z] [2022-09-27T08:55:06.557Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > testStickyTaskAssignorManyThreadsPerClient PASSED [2022-09-27T08:55:06.557Z] [2022-09-27T08:55:06.557Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > testFallbackPriorTaskAssignorManyThreadsPerClient STARTED [2022-09-27T08:55:07.874Z] [2022-09-27T08:55:07.874Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > testFallbackPriorTaskAssignorManyThreadsPerClient PASSED [2022-09-27T08:55:07.874Z] [2022-09-27T08:55:07.874Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > testFallbackPriorTaskAssignorLargePartitionCount STARTED [2022-09-27T08:55:35.458Z] [2022-09-27T08:55:35.458Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > testFallbackPriorTaskAssignorLargePartitionCount PASSED [2022-09-27T08:55:35.458Z] [2022-09-27T08:55:35.458Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > testStickyTaskAssignorLargePartitionCount STARTED [2022-09-27T08:56:00.437Z] [2022-09-27T08:56:00.437Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > testStickyTaskAssignorLargePartitionCount PASSED [2022-09-27T08:56:00.437Z] [2022-09-27T08:56:00.437Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > testFallbackPriorTaskAssignorManyStandbys STARTED [2022-09-27T08:56:05.531Z] [2022-09-27T08:56:05.531Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > testFallbackPriorTaskAssignorManyStandbys PASSED [2022-09-27T08:56:05.531Z] [2022-09-27T08:56:05.531Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > testHighAvailabilityTaskAssignorManyStandbys STARTED [2022-09-27T08:56:25.984Z] [2022-09-27T08:56:25.984Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > testHighAvailabilityTaskAssignorManyStandbys PASSED [2022-09-27T08:56:25.984Z] [2022-09-27T08:56:25.984Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > testFallbackPriorTaskAssignorLargeNumConsumers STARTED [2022-09-27T08:56:27.231Z] [2022-09-27T08:56:27.231Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > testFallbackPriorTaskAssignorLargeNumConsumers PASSED [2022-09-27T08:56:27.231Z] [2022-09-27T08:56:27.231Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > testStickyTaskAssignorLargeNumConsumers STARTED [2022-09-27T08:56:29.029Z] [2022-09-27T08:56:29.029Z] org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest > testStickyTaskAssignorLargeNumConsumers PASSED [2022-09-27T08:56:30.274Z] streams-1: SMOKE-TEST-CLIENT-CLOSED [2022-09-27T08:56:30.274Z] streams-5: SMOKE-TEST-CLIENT-CLOSED [2022-09-27T08:56:30.274Z] streams-2: SMOKE-TEST-CLIENT-CLOSED [2022-09-27T08:56:30.274Z] streams-6: SMOKE-TEST-CLIENT-CLOSED [2022-09-27T08:56:30.274Z] streams-3: SMOKE-TEST-CLIENT-CLOSED [2022-09-27T08:56:30.274Z] streams-0: SMOKE-TEST-CLIENT-CLOSED [2022-09-27T08:56:30.274Z] streams-4: SMOKE-TEST-CLIENT-CLOSED [2022-09-27T08:56:37.600Z] [2022-09-27T08:56:37.600Z] org.apache.kafka.streams.integration.EosIntegrationTest > shouldWriteLatestOffsetsToCheckpointOnShutdown[exactly_once] STARTED [2022-09-27T08:56:37.600Z] [2022-09-27T08:56:37.600Z] org.apache.kafka.streams.integration.RackAwarenessIntegrationTest > shouldDoRebalancingWithMaximumNumberOfClientTags STARTED [2022-09-27T08:56:52.676Z] [2022-09-27T08:56:52.676Z] org.apache.kafka.streams.integration.EosIntegrationTest > shouldWriteLatestOffsetsToCheckpointOnShutdown[exactly_once] PASSED [2022-09-27T08:56:55.461Z] [2022-09-27T08:56:55.461Z] org.apache.kafka.streams.integration.RackAwarenessIntegrationTest > shouldDoRebalancingWithMaximumNumberOfClientTags PASSED [2022-09-27T08:56:55.461Z] [2022-09-27T08:56:55.461Z] org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest > shouldRestoreAfterJoinRestart[ON_WINDOW_UPDATE_cache:true] STARTED [2022-09-27T08:57:46.366Z] [2022-09-27T08:57:46.366Z] org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest > shouldRestoreAfterJoinRestart[ON_WINDOW_UPDATE_cache:true] PASSED [2022-09-27T08:57:52.612Z] [2022-09-27T08:57:52.612Z] 649 tests completed, 3 failed [2022-09-27T08:57:56.715Z] There were failing tests. See the report at: file:///home/jenkins/jenkins-agent/workspace/Kafka_kafka_3.3/streams/build/reports/tests/integrationTest/index.html [2022-09-27T08:57:57.860Z] [2022-09-27T08:57:57.860Z] BUILD SUCCESSFUL in 3h 9m 21s [2022-09-27T08:57:57.860Z] 212 actionable tasks: 115 executed, 97 up-to-date [2022-09-27T08:57:57.860Z] [2022-09-27T08:57:57.860Z] See the profiling report at: file:///home/jenkins/jenkins-agent/workspace/Kafka_kafka_3.3/build/reports/profile/profile-2022-09-27-05-48-39.html [2022-09-27T08:57:57.860Z] A fine-grained performance profile is available: use the --scan option. [Pipeline] junit [2022-09-27T08:57:58.723Z] Recording test results [2022-09-27T08:58:13.011Z] [Checks API] No suitable checks publisher found. [Pipeline] echo [2022-09-27T08:58:13.012Z] Skipping Kafka Streams archetype test for Java 17 [Pipeline] } [Pipeline] // withEnv [Pipeline] } [Pipeline] // withEnv [Pipeline] } [Pipeline] // withEnv [Pipeline] } [Pipeline] // node [Pipeline] } [Pipeline] // timestamps [Pipeline] } [Pipeline] // timeout [Pipeline] } [Pipeline] // stage [Pipeline] } [Pipeline] // parallel [Pipeline] } [Pipeline] // stage [Pipeline] stage [Pipeline] { (Declarative: Post Actions) [Pipeline] node Still waiting to schedule task Waiting for next available executor on ‘ubuntu’ Running on builds23 in /home/jenkins/workspace/Kafka_kafka_3.3 [Pipeline] { [Pipeline] script [Pipeline] { [Pipeline] step