root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity

trivial fix to include violated payload size in MessageSizeTooLargeException; patched by Jun Rao 

git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/trunk@1298030 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Jun Rao 2012-03-07 17:51:21 +00:00
parent 0443e2dd73
commit 624a361e01
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
core/src/main/scala/kafka/common/ErrorMapping.scala
View File

@ -58,5 +58,4 @@ class InvalidTopicException(message: String) extends RuntimeException(message) {
}
class MessageSizeTooLargeException(message: String) extends RuntimeException(message) {
def this() = this(null)
}

5
core/src/main/scala/kafka/message/ByteBufferMessageSet.scala
View File

@ -82,8 +82,9 @@ class ByteBufferMessageSet(private val buffer: ByteBuffer,
var shallowIter = internalIterator(true)
while(shallowIter.hasNext){
var messageAndOffset = shallowIter.next
if (messageAndOffset.message.payloadSize > maxMessageSize)
throw new MessageSizeTooLargeException
val payloadSize = messageAndOffset.message.payloadSize
if ( payloadSize > maxMessageSize)
throw new MessageSizeTooLargeException("payload size of " + payloadSize + " larger than " + maxMessageSize)
}
}