[jira] [Updated] (KAFKA-277) Add a shallow iterator to the ByteBufferMessageSet, which is only used in SynchProducer.verifyMessageSize() function

["Yang Ye (Updated) (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Yang Ye updated KAFKA-277:
--------------------------

    Attachment: shallow_iterator.patch

The lastConnectionTime adjustment is also in this patch.

Also the following file is also affected. Curious, in the repository copy, the variable "event" has no context (an variable not defined), only when I change it to events the make process can succeed. 

--- core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala  (revision 1245727)
+++ core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala  (working copy)
@@ -38,8 +38,8 @@
       processedEvents = cbkHandler.beforeSendingData(events)

     if(logger.isTraceEnabled)
-      processedEvents.foreach(event => trace("Handling event for Topic: %s, Partition: %d"
-        .format(event.getTopic, event.getPartition)))
+      processedEvents.foreach(events => trace("Handling event for Topic: %s, Partition: %d"
+        .format(events.getTopic, events.getPartition)))

     send(serialize(collate(processedEvents), serializer), syncProducer)
   }

                
> Add a shallow iterator to the ByteBufferMessageSet, which is only used in SynchProducer.verifyMessageSize() function
> --------------------------------------------------------------------------------------------------------------------
>
>                 Key: KAFKA-277
>                 URL: https://issues.apache.org/jira/browse/KAFKA-277
>             Project: Kafka
>          Issue Type: Bug
>            Reporter: Yang Ye
>         Attachments: shallow_iterator.patch
>
>
> Shallow iterator just traverse the first level messages of a ByteBufferMessageSet, compressed messages won't be decompressed and treated individually 

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira