fix OOM problem when receive big response of SSE interface from backend (#5148)

Author: thisAmateur

.github/workflows/checkstyle.yml

@@ -26,7 +26,7 @@ on:
 jobs:
   checkstyle:
     timeout-minutes: 60
-    runs-on: ubuntu-latest
+    runs-on: ubuntu-24.04
     steps:
       - uses: actions/checkout@v3
       - name: Set up jdk

.github/workflows/maven.yml

@@ -29,7 +29,7 @@ jobs:
   build:
 
     timeout-minutes: 60
-    runs-on: ubuntu-latest
+    runs-on: ubuntu-24.04
 
     steps:
     - uses: actions/checkout@v3

.github/workflows/rat_check.yml

@@ -29,7 +29,7 @@ on:
 jobs:
   rat_check:
     timeout-minutes: 60
-    runs-on: ubuntu-latest
+    runs-on: ubuntu-24.04
     steps:
       - uses: actions/checkout@v3
       - name: Set up jdk

.github/workflows/spotbugs.yml

@@ -26,7 +26,7 @@ on:
 jobs:
   spotbugs:
     timeout-minutes: 60
-    runs-on: ubuntu-latest
+    runs-on: ubuntu-24.04
     steps:
       - uses: actions/checkout@v3
       - name: Set up jdk

.github/workflows/unit-test-jdk17.yml

@@ -27,7 +27,7 @@ on:
 jobs:
   unit-tests:
     timeout-minutes: 60
-    runs-on: ubuntu-latest
+    runs-on: ubuntu-24.04
     steps:
       - uses: actions/checkout@v3
       - name: Set up jdk

.github/workflows/unit-test-jdk21.yml

@@ -27,7 +27,7 @@ on:
 jobs:
   unit-tests:
     timeout-minutes: 60
-    runs-on: ubuntu-latest
+    runs-on: ubuntu-24.04
     steps:
       - uses: actions/checkout@v3
       - name: Set up jdk

common/common-rest/src/main/java/org/apache/servicecomb/common/rest/codec/produce/ProduceEventStreamProcessor.java

@@ -325,6 +325,7 @@ private void processStringLine(String line) {
 
   private byte[] readALineOfBytesFromBuffer(ByteBuf buffer) {
     matchingDelimiterIndex = 0;
+    int newLineStartPos = buffer.readerIndex();
     try (final ByteArrayOutputStream bos = new ByteArrayOutputStream(buffer.readableBytes())) {
       while (buffer.readableBytes() > 0 && matchingDelimiterIndex < lineDelimiterBytes.length) {
         final byte b = buffer.readByte();
@@ -336,7 +337,7 @@ private byte[] readALineOfBytesFromBuffer(ByteBuf buffer) {
       if (matchingDelimiterIndex < lineDelimiterBytes.length) {
         // The newline character was not matched, so this part of the buffer does not constitute a complete line of
         // content and needs to remain in the buffer, waiting for the next segment to arrive for processing.
-        buffer.writeBytes(bos.toByteArray());
+        buffer.readerIndex(newLineStartPos);
         return null;
       }
       matchingDelimiterIndex = 0;