in src/main/java/com/aliyun/openservices/aliyun/log/producer/internals/LogAccumulator.java [247:261]
private void ensureValidLogSize(int sizeInBytes) throws LogSizeTooLargeException {
if (sizeInBytes > ProducerConfig.MAX_BATCH_SIZE_IN_BYTES) {
throw new LogSizeTooLargeException(
"the logs is "
+ sizeInBytes
+ " bytes which is larger than MAX_BATCH_SIZE_IN_BYTES "
+ ProducerConfig.MAX_BATCH_SIZE_IN_BYTES);
}
if (sizeInBytes > producerConfig.getTotalSizeInBytes()) {
throw new LogSizeTooLargeException(
"the logs is "
+ sizeInBytes
+ " bytes which is larger than the totalSizeInBytes you specified");
}
}