2026-03-03 07:50:52,513 [lthMonitorDaemonTask] [ ] [ ] [ ] (nal.HealthStatusAggregatorImpl) ERROR - Health check 'streamservice-check' reported a failure. Response: '{"last_reported_time":"2026-03-03T07:50:52.513Z","message":"StreamService state is STOPPED","test_name":"Streamservice-Check","status":"failure"}'
2026-03-03 07:50:58,757 [22,23,3,4,5,6,7,8,9]] [ STANDARD] [ ] [ ] ( DelayedItemsDataFlow) ERROR - Skipping loading and processing delayed messages. Stream service is not available.
2026-03-03 07:50:59,392 [r], Partitions=[4,5]] [ STANDARD] [ ] [ ] (w.listener.RetryLoggerListener) ERROR - [pxInteractionAggregator] Preparing retry 3515. Next attempt in 2m on data flow [pxInteractionAggregator] on stage [InputStage] with affected partitions: [4, 5]
java.util.concurrent.CompletionException: com.pega.fnx.stream.spi.StreamServiceException: Invalid configuration. Undefined stream provider end point.
at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273) ~[?:1.8.0_422]
at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280) ~[?:1.8.0_422]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1606) ~[?:1.8.0_422]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_422]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_422]
at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_422]
Caused by: com.pega.fnx.stream.spi.StreamServiceException: Invalid configuration. Undefined stream provider end point.
at com.pega.fnx.stream.spi.impl.kafka.KafkaAdminSettings.getBootstrapServers(KafkaAdminSettings.java:75) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaSettingsProvider.applyCommonProperties(KafkaSettingsProvider.java:77) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaSettingsProvider.getDefaultAdminClientProperties(KafkaSettingsProvider.java:71) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaServerImpl.getAdminClient(KafkaServerImpl.java:63) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.getAdminClient(CreateStreamRequestProcessor.java:139) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.createStream(CreateStreamRequestProcessor.java:76) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.lambda$execute$0(CreateStreamRequestProcessor.java:66) ~[?:?]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604) ~[?:1.8.0_422]
... 3 more
2026-03-03 07:51:07,514 [lthMonitorDaemonTask] [ ] [ ] [ ] (nal.HealthStatusAggregatorImpl) ERROR - Health check 'streamservice-check' reported a failure. Response: '{"last_reported_time":"2026-03-03T07:51:07.514Z","message":"StreamService state is STOPPED","test_name":"Streamservice-Check","status":"failure"}'
2026-03-03 07:51:08,361 [sor], Partitions=[5]] [ STANDARD] [ ] [ ] (w.listener.RetryLoggerListener) ERROR - [pyBIBatchIndexProcessor] Preparing retry 3524. Next attempt in 2m on data flow [pyBIBatchIndexProcessor] on stage [InputStage] with affected partitions: [5]
java.util.concurrent.CompletionException: com.pega.fnx.stream.spi.StreamServiceException: Invalid configuration. Undefined stream provider end point.
at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273) ~[?:1.8.0_422]
at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280) ~[?:1.8.0_422]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1606) ~[?:1.8.0_422]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_422]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_422]
at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_422]
Caused by: com.pega.fnx.stream.spi.StreamServiceException: Invalid configuration. Undefined stream provider end point.
at com.pega.fnx.stream.spi.impl.kafka.KafkaAdminSettings.getBootstrapServers(KafkaAdminSettings.java:75) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaSettingsProvider.applyCommonProperties(KafkaSettingsProvider.java:77) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaSettingsProvider.getDefaultAdminClientProperties(KafkaSettingsProvider.java:71) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaServerImpl.getAdminClient(KafkaServerImpl.java:63) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.getAdminClient(CreateStreamRequestProcessor.java:139) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.createStream(CreateStreamRequestProcessor.java:76) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.lambda$execute$0(CreateStreamRequestProcessor.java:66) ~[?:?]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604) ~[?:1.8.0_422]
... 3 more
2026-03-03 07:51:08,759 [22,23,3,4,5,6,7,8,9]] [ STANDARD] [ ] [ ] ( DelayedItemsDataFlow) ERROR - Skipping loading and processing delayed messages. Stream service is not available.
2026-03-03 07:51:16,369 [, Partitions=[0,1,2]] [ STANDARD] [ ] [ ] (w.listener.RetryLoggerListener) ERROR - [pzAttachmentMigrationProcessor] Preparing retry 3510. Next attempt in 2m on data flow [pzAttachmentMigrationProcessor] on stage [InputStage] with affected partitions: [0, 1, 2]
java.util.concurrent.CompletionException: com.pega.fnx.stream.spi.StreamServiceException: Invalid configuration. Undefined stream provider end point.
at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273) ~[?:1.8.0_422]
at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280) ~[?:1.8.0_422]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1606) ~[?:1.8.0_422]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_422]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_422]
at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_422]
Caused by: com.pega.fnx.stream.spi.StreamServiceException: Invalid configuration. Undefined stream provider end point.
at com.pega.fnx.stream.spi.impl.kafka.KafkaAdminSettings.getBootstrapServers(KafkaAdminSettings.java:75) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaSettingsProvider.applyCommonProperties(KafkaSettingsProvider.java:77) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaSettingsProvider.getDefaultAdminClientProperties(KafkaSettingsProvider.java:71) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaServerImpl.getAdminClient(KafkaServerImpl.java:63) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.getAdminClient(CreateStreamRequestProcessor.java:139) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.createStream(CreateStreamRequestProcessor.java:76) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.lambda$execute$0(CreateStreamRequestProcessor.java:66) ~[?:?]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604) ~[?:1.8.0_422]
... 3 more
2026-03-03 07:51:17,469 [itions=[0,1,2,3,4,5]] [ STANDARD] [ ] [ ] (w.listener.RetryLoggerListener) ERROR - [pzTakeExecMonSnapshot] Preparing retry 3506. Next attempt in 2m on data flow [pzTakeExecMonSnapshot] on stage [InputStage] with affected partitions: [0, 1, 2, 3, 4, 5]
java.util.concurrent.CompletionException: com.pega.fnx.stream.spi.StreamServiceException: Invalid configuration. Undefined stream provider end point.
at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273) ~[?:1.8.0_422]
at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280) ~[?:1.8.0_422]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1606) ~[?:1.8.0_422]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_422]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_422]
at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_422]
Caused by: com.pega.fnx.stream.spi.StreamServiceException: Invalid configuration. Undefined stream provider end point.
at com.pega.fnx.stream.spi.impl.kafka.KafkaAdminSettings.getBootstrapServers(KafkaAdminSettings.java:75) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaSettingsProvider.applyCommonProperties(KafkaSettingsProvider.java:77) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaSettingsProvider.getDefaultAdminClientProperties(KafkaSettingsProvider.java:71) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaServerImpl.getAdminClient(KafkaServerImpl.java:63) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.getAdminClient(CreateStreamRequestProcessor.java:139) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.createStream(CreateStreamRequestProcessor.java:76) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.lambda$execute$0(CreateStreamRequestProcessor.java:66) ~[?:?]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604) ~[?:1.8.0_422]
... 3 more
2026-03-03 07:51:17,997 [, Partitions=[0,1,2]] [ STANDARD] [ ] [ ] (w.listener.RetryLoggerListener) ERROR - [pyBIIncrementalIndexer] Preparing retry 3503. Next attempt in 2m on data flow [pyBIIncrementalIndexer] on stage [InputStage] with affected partitions: [0, 1, 2]
java.util.concurrent.CompletionException: com.pega.fnx.stream.spi.StreamServiceException: Invalid configuration. Undefined stream provider end point.
at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273) ~[?:1.8.0_422]
at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280) ~[?:1.8.0_422]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1606) ~[?:1.8.0_422]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_422]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_422]
at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_422]
Caused by: com.pega.fnx.stream.spi.StreamServiceException: Invalid configuration. Undefined stream provider end point.
at com.pega.fnx.stream.spi.impl.kafka.KafkaAdminSettings.getBootstrapServers(KafkaAdminSettings.java:75) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaSettingsProvider.applyCommonProperties(KafkaSettingsProvider.java:77) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaSettingsProvider.getDefaultAdminClientProperties(KafkaSettingsProvider.java:71) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaServerImpl.getAdminClient(KafkaServerImpl.java:63) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.getAdminClient(CreateStreamRequestProcessor.java:139) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.createStream(CreateStreamRequestProcessor.java:76) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.lambda$execute$0(CreateStreamRequestProcessor.java:66) ~[?:?]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604) ~[?:1.8.0_422]
... 3 more
2026-03-03 07:51:18,877 [22,23,3,4,5,6,7,8,9]] [ STANDARD] [ ] [ ] ( DelayedItemsDataFlow) ERROR - Skipping loading and processing delayed messages. Stream service is not available.
2026-03-03 07:51:22,515 [lthMonitorDaemonTask] [ ] [ ] [ ] (nal.HealthStatusAggregatorImpl) ERROR - Health check 'streamservice-check' reported a failure. Response: '{"last_reported_time":"2026-03-03T07:51:22.515Z","message":"StreamService state is STOPPED","test_name":"Streamservice-Check","status":"failure"}'
2026-03-03 07:51:23,083 [sor], Partitions=[5]] [ STANDARD] [ ] [ ] (w.listener.RetryLoggerListener) ERROR - [pzStandardProcessor] Preparing retry 3519. Next attempt in 2m on data flow [pzStandardProcessor] on stage [InputStage] with affected partitions: [5]
java.util.concurrent.CompletionException: com.pega.fnx.stream.spi.StreamServiceException: Invalid configuration. Undefined stream provider end point.
at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273) ~[?:1.8.0_422]
at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280) ~[?:1.8.0_422]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1606) ~[?:1.8.0_422]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_422]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_422]
at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_422]
Caused by: com.pega.fnx.stream.spi.StreamServiceException: Invalid configuration. Undefined stream provider end point.
at com.pega.fnx.stream.spi.impl.kafka.KafkaAdminSettings.getBootstrapServers(KafkaAdminSettings.java:75) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaSettingsProvider.applyCommonProperties(KafkaSettingsProvider.java:77) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaSettingsProvider.getDefaultAdminClientProperties(KafkaSettingsProvider.java:71) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaServerImpl.getAdminClient(KafkaServerImpl.java:63) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.getAdminClient(CreateStreamRequestProcessor.java:139) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.createStream(CreateStreamRequestProcessor.java:76) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.lambda$execute$0(CreateStreamRequestProcessor.java:66) ~[?:?]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604) ~[?:1.8.0_422]
... 3 more
2026-03-03 07:51:28,616 [, Partitions=[3,4,5]] [ STANDARD] [ ] [ ] (w.listener.RetryLoggerListener) ERROR - [pyFTSIncrementalIndexer] Preparing retry 3516. Next attempt in 2m on data flow [pyFTSIncrementalIndexer] on stage [InputStage] with affected partitions: [3, 4, 5]
java.util.concurrent.CompletionException: com.pega.fnx.stream.spi.StreamServiceException: Invalid configuration. Undefined stream provider end point.
at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273) ~[?:1.8.0_422]
at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280) ~[?:1.8.0_422]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1606) ~[?:1.8.0_422]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_422]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_422]
at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_422]
Caused by: com.pega.fnx.stream.spi.StreamServiceException: Invalid configuration. Undefined stream provider end point.
at com.pega.fnx.stream.spi.impl.kafka.KafkaAdminSettings.getBootstrapServers(KafkaAdminSettings.java:75) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaSettingsProvider.applyCommonProperties(KafkaSettingsProvider.java:77) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaSettingsProvider.getDefaultAdminClientProperties(KafkaSettingsProvider.java:71) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaServerImpl.getAdminClient(KafkaServerImpl.java:63) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.getAdminClient(CreateStreamRequestProcessor.java:139) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.createStream(CreateStreamRequestProcessor.java:76) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.lambda$execute$0(CreateStreamRequestProcessor.java:66) ~[?:?]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604) ~[?:1.8.0_422]
... 3 more
2026-03-03 07:51:28,878 [22,23,3,4,5,6,7,8,9]] [ STANDARD] [ ] [ ] ( DelayedItemsDataFlow) ERROR - Skipping loading and processing delayed messages. Stream service is not available.
2026-03-03 07:51:33,889 [r], Partitions=[2,3]] [ STANDARD] [ ] [ ] (w.listener.RetryLoggerListener) ERROR - [pzStandardProcessor] Preparing retry 3730. Next attempt in 2m on data flow [pzStandardProcessor] on stage [InputStage] with affected partitions: [2, 3]
java.util.concurrent.CompletionException: com.pega.fnx.stream.spi.StreamServiceException: Invalid configuration. Undefined stream provider end point.
at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273) ~[?:1.8.0_422]
at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280) ~[?:1.8.0_422]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1606) ~[?:1.8.0_422]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_422]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_422]
at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_422]
Caused by: com.pega.fnx.stream.spi.StreamServiceException: Invalid configuration. Undefined stream provider end point.
at com.pega.fnx.stream.spi.impl.kafka.KafkaAdminSettings.getBootstrapServers(KafkaAdminSettings.java:75) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaSettingsProvider.applyCommonProperties(KafkaSettingsProvider.java:77) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaSettingsProvider.getDefaultAdminClientProperties(KafkaSettingsProvider.java:71) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaServerImpl.getAdminClient(KafkaServerImpl.java:63) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.getAdminClient(CreateStreamRequestProcessor.java:139) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.createStream(CreateStreamRequestProcessor.java:76) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.lambda$execute$0(CreateStreamRequestProcessor.java:66) ~[?:?]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604) ~[?:1.8.0_422]
... 3 more
2026-03-03 07:51:33,989 [sor], Partitions=[4]] [ STANDARD] [ ] [ ] (w.listener.RetryLoggerListener) ERROR - [pzStandardProcessor] Preparing retry 3728. Next attempt in 2m on data flow [pzStandardProcessor] on stage [InputStage] with affected partitions: [4]
java.util.concurrent.CompletionException: com.pega.fnx.stream.spi.StreamServiceException: Invalid configuration. Undefined stream provider end point.
at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273) ~[?:1.8.0_422]
at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280) ~[?:1.8.0_422]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1606) ~[?:1.8.0_422]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_422]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_422]
at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_422]
Caused by: com.pega.fnx.stream.spi.StreamServiceException: Invalid configuration. Undefined stream provider end point.
at com.pega.fnx.stream.spi.impl.kafka.KafkaAdminSettings.getBootstrapServers(KafkaAdminSettings.java:75) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaSettingsProvider.applyCommonProperties(KafkaSettingsProvider.java:77) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaSettingsProvider.getDefaultAdminClientProperties(KafkaSettingsProvider.java:71) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaServerImpl.getAdminClient(KafkaServerImpl.java:63) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.getAdminClient(CreateStreamRequestProcessor.java:139) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.createStream(CreateStreamRequestProcessor.java:76) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.lambda$execute$0(CreateStreamRequestProcessor.java:66) ~[?:?]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604) ~[?:1.8.0_422]
... 3 more
2026-03-03 07:51:35,956 [, Partitions=[0,1,2]] [ STANDARD] [ ] [ ] (w.listener.RetryLoggerListener) ERROR - [pySASIncrementalIndexer] Preparing retry 3730. Next attempt in 2m on data flow [pySASIncrementalIndexer] on stage [InputStage] with affected partitions: [0, 1, 2]
java.util.concurrent.CompletionException: com.pega.fnx.stream.spi.StreamServiceException: Invalid configuration. Undefined stream provider end point.
at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273) ~[?:1.8.0_422]
at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280) ~[?:1.8.0_422]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1606) ~[?:1.8.0_422]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_422]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_422]
at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_422]
Caused by: com.pega.fnx.stream.spi.StreamServiceException: Invalid configuration. Undefined stream provider end point.
at com.pega.fnx.stream.spi.impl.kafka.KafkaAdminSettings.getBootstrapServers(KafkaAdminSettings.java:75) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaSettingsProvider.applyCommonProperties(KafkaSettingsProvider.java:77) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaSettingsProvider.getDefaultAdminClientProperties(KafkaSettingsProvider.java:71) ~[?:?]
at com.pega.fnx.stream.spi.impl.kafka.KafkaServerImpl.getAdminClient(KafkaServerImpl.java:63) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.getAdminClient(CreateStreamRequestProcessor.java:139) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.createStream(CreateStreamRequestProcessor.java:76) ~[?:?]
at com.pega.fnx.stream.spi.impl.processor.create.CreateStreamRequestProcessor.lambda$execute$0(CreateStreamRequestProcessor.java:66) ~[?:?]
at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604) ~[?:1.8.0_422]
... 3 more