Scala中的大块拆分字符串

Question

我是Scala的新手，我很难通过字节拆分字符串。

假设我有一个一定长度的字符串对象，问题是我需要将此字符串分开并将其发送给1048576（最大）字节的消费者。

到目前为止，我已经尝试了以下内容：

    val recordDelimiter: String = "\n"
    val recordsBatch: String = dataArray.mkString(recordDelimiter)
    val recordsCount = dataArray.length
    // Send data to stream

    recordsBatch
      .grouped(1048576)
      .foreach(
        chunk =>
          try {
            val putRecordRequest = PutRecordRequest.builder
              .streamName(streamName)
              .data(AWSUtils.toSdkBytes(chunk))
              .partitionKey("partitionKey-1")
              .build
            val response = kinesis.putRecord(putRecordRequest)
            logger.info(s"Records sent to $streamName stream: $recordsCount")
            response.sequenceNumber
          } catch {
            case exception: KinesisException =>
              logger.error("Error occurred while sending data to Kinesis", exception)
              "ERROR"
          } finally {
            kinesis.close()
          }
  )

但是，每次尝试执行代码