[GitHub] [kafka] dhruvilshah3 commented on pull request #5500: KAFKA-7286: Avoid getting stuck loading large metadata records

Thu, 06 Sep 2018 08:23:14 -0700 

Hmm, it seems like you should be able to do something like this:

```
            case fileRecords: FileRecords =>
              val sizeInBytes = fileRecords.sizeInBytes
              val recordsBuffer = 
ByteBuffer.allocate(Math.max(config.loadBufferSize, sizeInBytes))
              if (recordsBuffer.capacity > config.loadBufferSize)
                warn("...")
              fileRecords.readInto(recordsBuffer, 0)
              MemoryRecords.readableRecords(recordsBuffer)
```

[ Full content available at: https://github.com/apache/kafka/pull/5500 ]
This message was relayed via gitbox.apache.org for [email protected]

Reply via email to