Greengrass StreamManager export error

I have a custom gg component that collects multiple data streams and publishes to a single Kinesis stream. Stream manager ingests data correctly (I can see the data in the work folder), but I also have a lot of log errors that prevent data from coming to Kinesis.

• All data streams are newly created and were not used before
• 3 data streams that collect different data in the same gg component
• StreamManagerClient instance is reused among them

Error log that I see a lot for a different streams (including new ones)

2023-10-06T14:04:39.681Z [INFO] (Copier) aws.greengrass.StreamManager: stdout. 2023 Oct 06 14:04:39,680 [ERROR] (pool-7-thread-2) com.amazonaws.iot.greengrass.streammanager.export.upload.MessageUploaderTask: Encountered Throwable when exporting messages. {scriptName=services.aws.greengrass.StreamManager.lifecycle.startup.script, serviceName=aws.greengrass.StreamManager, currentState=RUNNING}
2023-10-06T14:04:39.681Z [INFO] (Copier) aws.greengrass.StreamManager: stdout. com.amazonaws.iot.greengrass.streammanager.store.exceptions.InvalidStreamPositionException: Unable to find sequence number 2888279 in log file for stream iot. {scriptName=services.aws.greengrass.StreamManager.lifecycle.startup.script, serviceName=aws.greengrass.StreamManager, currentState=RUNNING}
2023-10-06T14:04:39.681Z [INFO] (Copier) aws.greengrass.StreamManager: stdout. at com.amazonaws.iot.greengrass.streammanager.store.log.FileLogSegment.read(FileLogSegment.java:274) ~[AWSGreengrassGreenlake-1.0-super.jar:?]. {scriptName=services.aws.greengrass.StreamManager.lifecycle.startup.script, serviceName=aws.greengrass.StreamManager, currentState=RUNNING}
2023-10-06T14:04:39.681Z [INFO] (Copier) aws.greengrass.StreamManager: stdout. at com.amazonaws.iot.greengrass.streammanager.store.log.MessageStreamLog.read(MessageStreamLog.java:379) ~[AWSGreengrassGreenlake-1.0-super.jar:?]. {scriptName=services.aws.greengrass.StreamManager.lifecycle.startup.script, serviceName=aws.greengrass.StreamManager, currentState=RUNNING}
2023-10-06T14:04:39.681Z [INFO] (Copier) aws.greengrass.StreamManager: stdout. at com.amazonaws.iot.greengrass.streammanager.store.log.MessageInputStreamHandleLogImpl.read(MessageInputStreamHandleLogImpl.java:32) ~[AWSGreengrassGreenlake-1.0-super.jar:?]. {scriptName=services.aws.greengrass.StreamManager.lifecycle.startup.script, serviceName=aws.greengrass.StreamManager, currentState=RUNNING}
2023-10-06T14:04:39.681Z [INFO] (Copier) aws.greengrass.StreamManager: stdout. at com.amazonaws.iot.greengrass.streammanager.export.upload.MessageUploaderTask.upload(MessageUploaderTask.java:66) ~[AWSGreengrassGreenlake-1.0-super.jar:?]. {scriptName=services.aws.greengrass.StreamManager.lifecycle.startup.script, serviceName=aws.greengrass.StreamManager, currentState=RUNNING}
2023-10-06T14:04:39.681Z [INFO] (Copier) aws.greengrass.StreamManager: stdout. at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1700) [?:?]. {scriptName=services.aws.greengrass.StreamManager.lifecycle.startup.script, serviceName=aws.greengrass.StreamManager, currentState=RUNNING}
2023-10-06T14:04:39.681Z [INFO] (Copier) aws.greengrass.StreamManager: stdout. at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]. {scriptName=services.aws.greengrass.StreamManager.lifecycle.startup.script, serviceName=aws.greengrass.StreamManager, currentState=RUNNING}
2023-10-06T14:04:39.681Z [INFO] (Copier) aws.greengrass.StreamManager: stdout. at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]. {scriptName=services.aws.greengrass.StreamManager.lifecycle.startup.script, serviceName=aws.greengrass.StreamManager, currentState=RUNNING}
2023-10-06T14:04:39.681Z [INFO] (Copier) aws.greengrass.StreamManager: stdout. at java.lang.Thread.run(Thread.java:829) [?:?]. {scriptName=services.aws.greengrass.StreamManager.lifecycle.startup.script, serviceName=aws.greengrass.StreamManager, currentState=RUNNING}

Component logic

STREAM_MANAGER_CLIENT = StreamManagerClient()

def on_a():
    ...
    STREAM_MANAGER_CLIENT.append_message("Av1", data=encoded_msg)

def on_b():
    ...
    STREAM_MANAGER_CLIENT.append_message("Bv1", data=encoded_msg)

def on_c():
    ...
    STREAM_MANAGER_CLIENT.append_message("Cv1", data=encoded_msg)


def create_stream_definition(identifier, version):
    kinesisConfig = KinesisConfig(identifier="KinesisExport" + identifier + version, kinesis_stream_name=STREAM_NAME)
    exportDefinition = ExportDefinition(kinesis=[kinesisConfig])

    streamDefinition = MessageStreamDefinition(
        name=identifier + version,  # Required.
        stream_segment_size=1024,
        strategy_on_full=StrategyOnFull.OverwriteOldestData,  # Required.
        export_definition=exportDefinition
    )

    return streamDefinition


def init_stream_client():
    try:
        STREAM_MANAGER_CLIENT.create_message_stream(create_stream_definition("A", "v1"))
        STREAM_MANAGER_CLIENT.create_message_stream(create_stream_definition("B", "v1"))
        STREAM_MANAGER_CLIENT.create_message_stream(create_stream_definition("C", "v1"))
    except InvalidRequestException as e:
        print("Exception occurred", file=sys.stderr)
        traceback.print_exc()

        if "the message stream already exists" in str(e):
            print("Message stream exists. Ignoring exception. ")
        else:
            raise

if __name__ == '__main__':
    init_stream_client()