Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # dev >> Re: svn commit: r1296577 - in /incubator/kafka/branches/0.8/core/src: main/scala/kafka/api/ main/scala/kafka/javaapi/ main/scala/kafka/javaapi/message/ main/scala/kafka/javaapi/producer/ main/scala/kafka/message/ main/scala/kafka/producer/ main/scala


Copy link to this message
-
Re: svn commit: r1296577 - in /incubator/kafka/branches/0.8/core/src: main/scala/kafka/api/ main/scala/kafka/javaapi/ main/scala/kafka/javaapi/message/ main/scala/kafka/javaapi/producer/ main/scala/kafka/message/ main/scala/kafka/producer/ main/scala
let me take care of the missing file right now, sorry about that

if now is a good time to rebase the 0.8 branch to the latest trunk then yes
I can help with that probably won't have time until Thursday at the soonest
I think

On Tue, Mar 6, 2012 at 12:33 PM, Neha Narkhede <[EMAIL PROTECTED]>wrote:

> Also, I would recommend rebasing the 0.8 branch to the latest trunk
> now. It has been quite a while since the last time I did a rebase.
>
> Joe, would you mind helping with that ?
>
> Thanks,
> Neha
>
> On Tue, Mar 6, 2012 at 9:15 AM, Jun Rao <[EMAIL PROTECTED]> wrote:
> > Joe,
> >
> > 0.8 now has compilation error after this check in. It seems that you
> forgot
> > to check in a new file. See my comment in kafka-240. Could you fix this?
> >
> > Thanks,
> >
> > Jun
> >
> > On Fri, Mar 2, 2012 at 9:46 PM, <[EMAIL PROTECTED]> wrote:
> >
> >> Author: joestein
> >> Date: Sat Mar  3 05:46:43 2012
> >> New Revision: 1296577
> >>
> >> URL: http://svn.apache.org/viewvc?rev=1296577&view=rev
> >> Log:
> >> KAFKA-240 ProducerRequest wire format protocol update and related
> changes
> >>
> >> Removed:
> >>
> >>
>  incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/MultiProducerRequest.scala
> >>
> >>
>  incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/MultiMessageSetSend.scala
> >> Modified:
> >>
> >>
>  incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/FetchResponse.scala
> >>
> >>
>  incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/ProducerRequest.scala
> >>
> >>
>  incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/FetchResponse.scala
> >>
> >>
>  incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/ProducerRequest.scala
> >>
> >>
>  incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/message/ByteBufferMessageSet.scala
> >>
> >>
>  incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/producer/SyncProducer.scala
> >>
> >>
>  incubator/kafka/branches/0.8/core/src/main/scala/kafka/message/ByteBufferMessageSet.scala
> >>
> >>
>  incubator/kafka/branches/0.8/core/src/main/scala/kafka/message/FileMessageSet.scala
> >>
> >>
>  incubator/kafka/branches/0.8/core/src/main/scala/kafka/message/MessageSet.scala
> >>
> >>
>  incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/SyncProducer.scala
> >>
> >>
>  incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/SyncProducerConfig.scala
> >>
> >>
>  incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala
> >>
> >>
>  incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaApis.scala
> >>
>  incubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/Utils.scala
> >>
> >>
>  incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/message/ByteBufferMessageSetTest.scala
> >>
> >>
>  incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/producer/AsyncProducerTest.scala
> >>
> >>
>  incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/producer/SyncProducerTest.scala
> >>
> >>
>  incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/utils/TestUtils.scala
> >>
> >> Modified:
> >>
> incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/FetchResponse.scala
> >> URL:
> >>
> http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/FetchResponse.scala?rev=1296577&r1=1296576&r2=1296577&view=diff
> >>
> >>
> =============================================================================> >> ---
> >>
> incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/FetchResponse.scala
> >> (original)
> >> +++
> >>
> incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/FetchResponse.scala
> >> Sat Mar  3 05:46:43 2012
> >> @@ -39,6 +39,15 @@ object PartitionData {
> >>
> >>  case class PartitionData(partition: Int, error: Int > >> ErrorMapping.NoError, initialOffset:Long = 0L, messages: MessageSet) {
> >>   val sizeInBytes = 4 + 4 + 8 + 4 + messages.sizeInBytes.intValue()
> >> +
> >> +  def this(partition: Int, messages: MessageSet) = this(partition,
/*
Joe Stein
http://www.linkedin.com/in/charmalloc
Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop>
*/
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB