You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by Jun Rao <ju...@confluent.io> on 2015/01/21 17:28:11 UTC
[VOTE] 0.8.2.0 Candidate 2 (with the correct links)
This is the second candidate for release of Apache Kafka 0.8.2.0. There has
been some changes since the 0.8.2 beta release, especially in the new java
producer api and jmx mbean names. It would be great if people can test this
out thoroughly.
Release Notes for the 0.8.2.0 release
https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
*** Please download, test and vote by Monday, Jan 26h, 7pm PT
Kafka's KEYS file containing PGP keys we use to sign the release:
http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2 (SHA256)
checksum.
* Release artifacts to be voted upon (source and binary):
https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
* Maven artifacts to be voted upon prior to release:
https://repository.apache.org/content/groups/staging/
* scala-doc
https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
* java-doc
https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
* The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
(commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
/*******************************************
Thanks,
Jun
Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Jun Rao <ju...@confluent.io>.
+1 (binding) Verified quick start and unit tests.
Thanks,
Jun
On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io> wrote:
> This is the second candidate for release of Apache Kafka 0.8.2.0. There
> has been some changes since the 0.8.2 beta release, especially in the new
> java producer api and jmx mbean names. It would be great if people can test
> this out thoroughly.
>
> Release Notes for the 0.8.2.0 release
>
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
>
> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
>
> Kafka's KEYS file containing PGP keys we use to sign the release:
> http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
> (SHA256) checksum.
>
> * Release artifacts to be voted upon (source and binary):
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
>
> * Maven artifacts to be voted upon prior to release:
> https://repository.apache.org/content/groups/staging/
>
> * scala-doc
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
>
> * java-doc
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
>
> * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
>
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
>
> /*******************************************
>
> Thanks,
>
> Jun
>
>
Re: [kafka-clients] Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Bhavesh Mistry <mi...@gmail.com>.
Hi Kafka Team,
I just wanted to bring this to your attention regarding Java New Producer
limitation compare to old producer.
a) Partition Increasing is limited to configured memory allocation.
buffer.memory
batch.size
The maximum partition you could have before impacting (New Java Producers)
producers is buffer.memory / batch.size. So Developer can plan for
horizontal scaling partition from the beginning otherwise production
running code will be impacted based on *block.on.buffer.full
configuration *(block
or BufferExhaustedException).
This limitation does not exits with old scala based Producer.
This will allow user community to buffer more and plan the capacity before
hand. May be add this info
http://kafka.apache.org/documentation.html#newproducerconfigs about
limitation.
Thanks,
Bhavesh
On Mon, Jan 26, 2015 at 10:28 AM, Joe Stein <jo...@stealth.ly> wrote:
> +1 (binding)
>
> artifacts and quick start look good. I ran in some client code, minor edits
> from 0-8.2-beta https://github.com/stealthly/scala-kafka/pull/26
>
> On Mon, Jan 26, 2015 at 3:38 AM, Manikumar Reddy <ku...@nmsworks.co.in>
> wrote:
>
> > +1 (Non-binding)
> > Verified source package, unit tests, release build, topic deletion,
> > compaction and random testing
> >
> > On Mon, Jan 26, 2015 at 6:14 AM, Neha Narkhede <ne...@confluent.io>
> wrote:
> >
> >> +1 (binding)
> >> Verified keys, quick start, unit tests.
> >>
> >> On Sat, Jan 24, 2015 at 4:26 PM, Joe Stein <jo...@stealth.ly>
> wrote:
> >>
> >> > That makes sense, thanks!
> >> >
> >> > On Sat, Jan 24, 2015 at 7:00 PM, Jay Kreps <ja...@gmail.com>
> wrote:
> >> >
> >> > > But I think the flaw in trying to guess what kind of serializer they
> >> will
> >> > > use is when we get it wrong. Basically let's say we guess "String".
> >> Say
> >> > 30%
> >> > > of the time we will be right and we will save the two configuration
> >> > lines.
> >> > > 70% of the time we will be wrong and the user gets a super cryptic
> >> > > ClassCastException: "xyz cannot be cast to [B" (because [B is how
> java
> >> > > chooses to display the byte array class just to up the pain), then
> >> they
> >> > > figure out how to subscribe to our mailing list and email us the
> >> cryptic
> >> > > exception, then we explain about how we helpfully set these
> properties
> >> > for
> >> > > them to save them time. :-)
> >> > >
> >> > >
> >>
> https://www.google.com/?gws_rd=ssl#q=kafka+classcastexception+%22%5BB%22
> >> > >
> >> > > I think basically we did this experiment with the old clients and
> the
> >> > > conclusion is that serialization is something you basically have to
> >> think
> >> > > about to use Kafka and trying to guess just makes things worse.
> >> > >
> >> > > -Jay
> >> > >
> >> > > On Sat, Jan 24, 2015 at 2:51 PM, Joe Stein <jo...@stealth.ly>
> >> wrote:
> >> > >
> >> > >> Maybe. I think the StringSerialzer could look more like a typical
> >> type
> >> > of
> >> > >> message. Instead of encoding being a property it would be more
> >> > typically
> >> > >> just written in the bytes.
> >> > >>
> >> > >> On Sat, Jan 24, 2015 at 12:12 AM, Jay Kreps <ja...@gmail.com>
> >> > wrote:
> >> > >>
> >> > >> > I don't think so--see if you buy my explanation. We previously
> >> > defaulted
> >> > >> > to the byte array serializer and it was a source of unending
> >> > frustration
> >> > >> > and confusion. Since it wasn't a required config people just went
> >> > along
> >> > >> > plugging in whatever objects they had, and thinking that changing
> >> the
> >> > >> > parametric types would somehow help. Then they would get a class
> >> case
> >> > >> > exception and assume our stuff was somehow busted, not realizing
> we
> >> > had
> >> > >> > helpfully configured a type different from what they were passing
> >> in
> >> > >> under
> >> > >> > the covers. So I think it is actually good for people to think:
> how
> >> > am I
> >> > >> > serializing my data, and getting that exception will make them
> ask
> >> > that
> >> > >> > question right?
> >> > >> >
> >> > >> > -Jay
> >> > >> >
> >> > >> > On Fri, Jan 23, 2015 at 9:06 PM, Joe Stein <joe.stein@stealth.ly
> >
> >> > >> wrote:
> >> > >> >
> >> > >> >> Should value.serializer in the new java producer be defaulted to
> >> > >> >> Array[Byte] ?
> >> > >> >>
> >> > >> >> I was working on testing some upgrade paths and got this
> >> > >> >>
> >> > >> >> ! return exception in callback when buffer cannot accept
> >> message
> >> > >> >>
> >> > >> >> ConfigException: Missing required configuration
> >> > >> "value.serializer"
> >> > >> >> which has no default value. (ConfigDef.java:124)
> >> > >> >>
> >> > >> >>
> >> org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:124)
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >>
> >> >
> >>
> org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:48)
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >>
> >> >
> >>
> org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:235)
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >>
> >> >
> >>
> org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:129)
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >>
> >> >
> >>
> ly.stealth.testing.BaseSpec$class.createNewKafkaProducer(BaseSpec.scala:42)
> >> > >> >>
> >> > >> >>
> >> > >>
> >> ly.stealth.testing.KafkaSpec.createNewKafkaProducer(KafkaSpec.scala:36)
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >>
> >> >
> >>
> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:175)
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >>
> >> >
> >>
> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:170)
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >> >> On Fri, Jan 23, 2015 at 5:55 PM, Jun Rao <ju...@confluent.io>
> >> wrote:
> >> > >> >>
> >> > >> >> > This is a reminder that the deadline for the vote is this
> >> Monday,
> >> > Jan
> >> > >> >> 26,
> >> > >> >> > 7pm PT.
> >> > >> >> >
> >> > >> >> > Thanks,
> >> > >> >> >
> >> > >> >> > Jun
> >> > >> >> >
> >> > >> >> > On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io>
> >> wrote:
> >> > >> >> >
> >> > >> >> >> This is the second candidate for release of Apache Kafka
> >> 0.8.2.0.
> >> > >> There
> >> > >> >> >> has been some changes since the 0.8.2 beta release,
> especially
> >> in
> >> > >> the
> >> > >> >> new
> >> > >> >> >> java producer api and jmx mbean names. It would be great if
> >> people
> >> > >> can
> >> > >> >> test
> >> > >> >> >> this out thoroughly.
> >> > >> >> >>
> >> > >> >> >> Release Notes for the 0.8.2.0 release
> >> > >> >> >>
> >> > >> >> >>
> >> > >> >>
> >> > >>
> >> >
> >>
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
> >> > >> >> >>
> >> > >> >> >> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
> >> > >> >> >>
> >> > >> >> >> Kafka's KEYS file containing PGP keys we use to sign the
> >> release:
> >> > >> >> >> http://kafka.apache.org/KEYS in addition to the md5, sha1
> and
> >> > sha2
> >> > >> >> >> (SHA256) checksum.
> >> > >> >> >>
> >> > >> >> >> * Release artifacts to be voted upon (source and binary):
> >> > >> >> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
> >> > >> >> >>
> >> > >> >> >> * Maven artifacts to be voted upon prior to release:
> >> > >> >> >> https://repository.apache.org/content/groups/staging/
> >> > >> >> >>
> >> > >> >> >> * scala-doc
> >> > >> >> >>
> >> > >>
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
> >> > >> >> >>
> >> > >> >> >> * java-doc
> >> > >> >> >>
> >> > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
> >> > >> >> >>
> >> > >> >> >> * The tag to be voted upon (off the 0.8.2 branch) is the
> >> 0.8.2.0
> >> > tag
> >> > >> >> >>
> >> > >> >> >>
> >> > >> >>
> >> > >>
> >> >
> >>
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> >> > >> >> >> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
> >> > >> >> >>
> >> > >> >> >> /*******************************************
> >> > >> >> >>
> >> > >> >> >> Thanks,
> >> > >> >> >>
> >> > >> >> >> Jun
> >> > >> >> >>
> >> > >> >> >>
> >> > >> >> > --
> >> > >> >> > You received this message because you are subscribed to the
> >> Google
> >> > >> >> Groups
> >> > >> >> > "kafka-clients" group.
> >> > >> >> > To unsubscribe from this group and stop receiving emails from
> >> it,
> >> > >> send
> >> > >> >> an
> >> > >> >> > email to kafka-clients+unsubscribe@googlegroups.com.
> >> > >> >> > To post to this group, send email to
> >> > kafka-clients@googlegroups.com.
> >> > >> >> > Visit this group at
> >> http://groups.google.com/group/kafka-clients.
> >> > >> >> > To view this discussion on the web visit
> >> > >> >> >
> >> > >> >>
> >> > >>
> >> >
> >>
> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com
> >> > >> >> > <
> >> > >> >>
> >> > >>
> >> >
> >>
> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com?utm_medium=email&utm_source=footer
> >> > >> >> >
> >> > >> >> > .
> >> > >> >> >
> >> > >> >> > For more options, visit https://groups.google.com/d/optout.
> >> > >> >> >
> >> > >> >>
> >> > >> >
> >> > >> > --
> >> > >> > You received this message because you are subscribed to the
> Google
> >> > >> Groups
> >> > >> > "kafka-clients" group.
> >> > >> > To unsubscribe from this group and stop receiving emails from it,
> >> send
> >> > >> an
> >> > >> > email to kafka-clients+unsubscribe@googlegroups.com.
> >> > >> > To post to this group, send email to
> >> kafka-clients@googlegroups.com.
> >> > >> > Visit this group at http://groups.google.com/group/kafka-clients
> .
> >> > >> > To view this discussion on the web visit
> >> > >> >
> >> > >>
> >> >
> >>
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com
> >> > >> > <
> >> > >>
> >> >
> >>
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com?utm_medium=email&utm_source=footer
> >> > >> >
> >> > >> > .
> >> > >> >
> >> > >> > For more options, visit https://groups.google.com/d/optout.
> >> > >> >
> >> > >>
> >> > >
> >> > > --
> >> > > You received this message because you are subscribed to the Google
> >> Groups
> >> > > "kafka-clients" group.
> >> > > To unsubscribe from this group and stop receiving emails from it,
> >> send an
> >> > > email to kafka-clients+unsubscribe@googlegroups.com.
> >> > > To post to this group, send email to kafka-clients@googlegroups.com
> .
> >> > > Visit this group at http://groups.google.com/group/kafka-clients.
> >> > > To view this discussion on the web visit
> >> > >
> >> >
> >>
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJgO6mvJ-y8pe6ik5GuDp%2BvufoJi-U23LqVnbjXWj16JMw%40mail.gmail.com
> >> > > <
> >> >
> >>
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJgO6mvJ-y8pe6ik5GuDp%2BvufoJi-U23LqVnbjXWj16JMw%40mail.gmail.com?utm_medium=email&utm_source=footer
> >> > >
> >> > > .
> >> > >
> >> > > For more options, visit https://groups.google.com/d/optout.
> >> > >
> >> >
> >>
> >>
> >>
> >> --
> >> Thanks,
> >> Neha
> >>
> >
> > --
> > You received this message because you are subscribed to the Google Groups
> > "kafka-clients" group.
> > To unsubscribe from this group and stop receiving emails from it, send an
> > email to kafka-clients+unsubscribe@googlegroups.com.
> > To post to this group, send email to kafka-clients@googlegroups.com.
> > Visit this group at http://groups.google.com/group/kafka-clients.
> > To view this discussion on the web visit
> >
> https://groups.google.com/d/msgid/kafka-clients/CAMVt_AzWHF3UJ-_d%2Bw_X2C0C%3DEBZyn2%2B049nvB4w7sJbg3jvtQ%40mail.gmail.com
> > <
> https://groups.google.com/d/msgid/kafka-clients/CAMVt_AzWHF3UJ-_d%2Bw_X2C0C%3DEBZyn2%2B049nvB4w7sJbg3jvtQ%40mail.gmail.com?utm_medium=email&utm_source=footer
> >
> > .
> >
> > For more options, visit https://groups.google.com/d/optout.
> >
>
Re: [kafka-clients] Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Bhavesh Mistry <mi...@gmail.com>.
Hi Kafka Team,
I just wanted to bring this to your attention regarding Java New Producer
limitation compare to old producer.
a) Partition Increasing is limited to configured memory allocation.
buffer.memory
batch.size
The maximum partition you could have before impacting (New Java Producers)
producers is buffer.memory / batch.size. So Developer can plan for
horizontal scaling partition from the beginning otherwise production
running code will be impacted based on *block.on.buffer.full
configuration *(block
or BufferExhaustedException).
This limitation does not exits with old scala based Producer.
This will allow user community to buffer more and plan the capacity before
hand. May be add this info
http://kafka.apache.org/documentation.html#newproducerconfigs about
limitation.
Thanks,
Bhavesh
On Mon, Jan 26, 2015 at 10:28 AM, Joe Stein <jo...@stealth.ly> wrote:
> +1 (binding)
>
> artifacts and quick start look good. I ran in some client code, minor edits
> from 0-8.2-beta https://github.com/stealthly/scala-kafka/pull/26
>
> On Mon, Jan 26, 2015 at 3:38 AM, Manikumar Reddy <ku...@nmsworks.co.in>
> wrote:
>
> > +1 (Non-binding)
> > Verified source package, unit tests, release build, topic deletion,
> > compaction and random testing
> >
> > On Mon, Jan 26, 2015 at 6:14 AM, Neha Narkhede <ne...@confluent.io>
> wrote:
> >
> >> +1 (binding)
> >> Verified keys, quick start, unit tests.
> >>
> >> On Sat, Jan 24, 2015 at 4:26 PM, Joe Stein <jo...@stealth.ly>
> wrote:
> >>
> >> > That makes sense, thanks!
> >> >
> >> > On Sat, Jan 24, 2015 at 7:00 PM, Jay Kreps <ja...@gmail.com>
> wrote:
> >> >
> >> > > But I think the flaw in trying to guess what kind of serializer they
> >> will
> >> > > use is when we get it wrong. Basically let's say we guess "String".
> >> Say
> >> > 30%
> >> > > of the time we will be right and we will save the two configuration
> >> > lines.
> >> > > 70% of the time we will be wrong and the user gets a super cryptic
> >> > > ClassCastException: "xyz cannot be cast to [B" (because [B is how
> java
> >> > > chooses to display the byte array class just to up the pain), then
> >> they
> >> > > figure out how to subscribe to our mailing list and email us the
> >> cryptic
> >> > > exception, then we explain about how we helpfully set these
> properties
> >> > for
> >> > > them to save them time. :-)
> >> > >
> >> > >
> >>
> https://www.google.com/?gws_rd=ssl#q=kafka+classcastexception+%22%5BB%22
> >> > >
> >> > > I think basically we did this experiment with the old clients and
> the
> >> > > conclusion is that serialization is something you basically have to
> >> think
> >> > > about to use Kafka and trying to guess just makes things worse.
> >> > >
> >> > > -Jay
> >> > >
> >> > > On Sat, Jan 24, 2015 at 2:51 PM, Joe Stein <jo...@stealth.ly>
> >> wrote:
> >> > >
> >> > >> Maybe. I think the StringSerialzer could look more like a typical
> >> type
> >> > of
> >> > >> message. Instead of encoding being a property it would be more
> >> > typically
> >> > >> just written in the bytes.
> >> > >>
> >> > >> On Sat, Jan 24, 2015 at 12:12 AM, Jay Kreps <ja...@gmail.com>
> >> > wrote:
> >> > >>
> >> > >> > I don't think so--see if you buy my explanation. We previously
> >> > defaulted
> >> > >> > to the byte array serializer and it was a source of unending
> >> > frustration
> >> > >> > and confusion. Since it wasn't a required config people just went
> >> > along
> >> > >> > plugging in whatever objects they had, and thinking that changing
> >> the
> >> > >> > parametric types would somehow help. Then they would get a class
> >> case
> >> > >> > exception and assume our stuff was somehow busted, not realizing
> we
> >> > had
> >> > >> > helpfully configured a type different from what they were passing
> >> in
> >> > >> under
> >> > >> > the covers. So I think it is actually good for people to think:
> how
> >> > am I
> >> > >> > serializing my data, and getting that exception will make them
> ask
> >> > that
> >> > >> > question right?
> >> > >> >
> >> > >> > -Jay
> >> > >> >
> >> > >> > On Fri, Jan 23, 2015 at 9:06 PM, Joe Stein <joe.stein@stealth.ly
> >
> >> > >> wrote:
> >> > >> >
> >> > >> >> Should value.serializer in the new java producer be defaulted to
> >> > >> >> Array[Byte] ?
> >> > >> >>
> >> > >> >> I was working on testing some upgrade paths and got this
> >> > >> >>
> >> > >> >> ! return exception in callback when buffer cannot accept
> >> message
> >> > >> >>
> >> > >> >> ConfigException: Missing required configuration
> >> > >> "value.serializer"
> >> > >> >> which has no default value. (ConfigDef.java:124)
> >> > >> >>
> >> > >> >>
> >> org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:124)
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >>
> >> >
> >>
> org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:48)
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >>
> >> >
> >>
> org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:235)
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >>
> >> >
> >>
> org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:129)
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >>
> >> >
> >>
> ly.stealth.testing.BaseSpec$class.createNewKafkaProducer(BaseSpec.scala:42)
> >> > >> >>
> >> > >> >>
> >> > >>
> >> ly.stealth.testing.KafkaSpec.createNewKafkaProducer(KafkaSpec.scala:36)
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >>
> >> >
> >>
> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:175)
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >>
> >> >
> >>
> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:170)
> >> > >> >>
> >> > >> >>
> >> > >> >>
> >> > >> >> On Fri, Jan 23, 2015 at 5:55 PM, Jun Rao <ju...@confluent.io>
> >> wrote:
> >> > >> >>
> >> > >> >> > This is a reminder that the deadline for the vote is this
> >> Monday,
> >> > Jan
> >> > >> >> 26,
> >> > >> >> > 7pm PT.
> >> > >> >> >
> >> > >> >> > Thanks,
> >> > >> >> >
> >> > >> >> > Jun
> >> > >> >> >
> >> > >> >> > On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io>
> >> wrote:
> >> > >> >> >
> >> > >> >> >> This is the second candidate for release of Apache Kafka
> >> 0.8.2.0.
> >> > >> There
> >> > >> >> >> has been some changes since the 0.8.2 beta release,
> especially
> >> in
> >> > >> the
> >> > >> >> new
> >> > >> >> >> java producer api and jmx mbean names. It would be great if
> >> people
> >> > >> can
> >> > >> >> test
> >> > >> >> >> this out thoroughly.
> >> > >> >> >>
> >> > >> >> >> Release Notes for the 0.8.2.0 release
> >> > >> >> >>
> >> > >> >> >>
> >> > >> >>
> >> > >>
> >> >
> >>
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
> >> > >> >> >>
> >> > >> >> >> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
> >> > >> >> >>
> >> > >> >> >> Kafka's KEYS file containing PGP keys we use to sign the
> >> release:
> >> > >> >> >> http://kafka.apache.org/KEYS in addition to the md5, sha1
> and
> >> > sha2
> >> > >> >> >> (SHA256) checksum.
> >> > >> >> >>
> >> > >> >> >> * Release artifacts to be voted upon (source and binary):
> >> > >> >> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
> >> > >> >> >>
> >> > >> >> >> * Maven artifacts to be voted upon prior to release:
> >> > >> >> >> https://repository.apache.org/content/groups/staging/
> >> > >> >> >>
> >> > >> >> >> * scala-doc
> >> > >> >> >>
> >> > >>
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
> >> > >> >> >>
> >> > >> >> >> * java-doc
> >> > >> >> >>
> >> > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
> >> > >> >> >>
> >> > >> >> >> * The tag to be voted upon (off the 0.8.2 branch) is the
> >> 0.8.2.0
> >> > tag
> >> > >> >> >>
> >> > >> >> >>
> >> > >> >>
> >> > >>
> >> >
> >>
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> >> > >> >> >> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
> >> > >> >> >>
> >> > >> >> >> /*******************************************
> >> > >> >> >>
> >> > >> >> >> Thanks,
> >> > >> >> >>
> >> > >> >> >> Jun
> >> > >> >> >>
> >> > >> >> >>
> >> > >> >> > --
> >> > >> >> > You received this message because you are subscribed to the
> >> Google
> >> > >> >> Groups
> >> > >> >> > "kafka-clients" group.
> >> > >> >> > To unsubscribe from this group and stop receiving emails from
> >> it,
> >> > >> send
> >> > >> >> an
> >> > >> >> > email to kafka-clients+unsubscribe@googlegroups.com.
> >> > >> >> > To post to this group, send email to
> >> > kafka-clients@googlegroups.com.
> >> > >> >> > Visit this group at
> >> http://groups.google.com/group/kafka-clients.
> >> > >> >> > To view this discussion on the web visit
> >> > >> >> >
> >> > >> >>
> >> > >>
> >> >
> >>
> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com
> >> > >> >> > <
> >> > >> >>
> >> > >>
> >> >
> >>
> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com?utm_medium=email&utm_source=footer
> >> > >> >> >
> >> > >> >> > .
> >> > >> >> >
> >> > >> >> > For more options, visit https://groups.google.com/d/optout.
> >> > >> >> >
> >> > >> >>
> >> > >> >
> >> > >> > --
> >> > >> > You received this message because you are subscribed to the
> Google
> >> > >> Groups
> >> > >> > "kafka-clients" group.
> >> > >> > To unsubscribe from this group and stop receiving emails from it,
> >> send
> >> > >> an
> >> > >> > email to kafka-clients+unsubscribe@googlegroups.com.
> >> > >> > To post to this group, send email to
> >> kafka-clients@googlegroups.com.
> >> > >> > Visit this group at http://groups.google.com/group/kafka-clients
> .
> >> > >> > To view this discussion on the web visit
> >> > >> >
> >> > >>
> >> >
> >>
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com
> >> > >> > <
> >> > >>
> >> >
> >>
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com?utm_medium=email&utm_source=footer
> >> > >> >
> >> > >> > .
> >> > >> >
> >> > >> > For more options, visit https://groups.google.com/d/optout.
> >> > >> >
> >> > >>
> >> > >
> >> > > --
> >> > > You received this message because you are subscribed to the Google
> >> Groups
> >> > > "kafka-clients" group.
> >> > > To unsubscribe from this group and stop receiving emails from it,
> >> send an
> >> > > email to kafka-clients+unsubscribe@googlegroups.com.
> >> > > To post to this group, send email to kafka-clients@googlegroups.com
> .
> >> > > Visit this group at http://groups.google.com/group/kafka-clients.
> >> > > To view this discussion on the web visit
> >> > >
> >> >
> >>
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJgO6mvJ-y8pe6ik5GuDp%2BvufoJi-U23LqVnbjXWj16JMw%40mail.gmail.com
> >> > > <
> >> >
> >>
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJgO6mvJ-y8pe6ik5GuDp%2BvufoJi-U23LqVnbjXWj16JMw%40mail.gmail.com?utm_medium=email&utm_source=footer
> >> > >
> >> > > .
> >> > >
> >> > > For more options, visit https://groups.google.com/d/optout.
> >> > >
> >> >
> >>
> >>
> >>
> >> --
> >> Thanks,
> >> Neha
> >>
> >
> > --
> > You received this message because you are subscribed to the Google Groups
> > "kafka-clients" group.
> > To unsubscribe from this group and stop receiving emails from it, send an
> > email to kafka-clients+unsubscribe@googlegroups.com.
> > To post to this group, send email to kafka-clients@googlegroups.com.
> > Visit this group at http://groups.google.com/group/kafka-clients.
> > To view this discussion on the web visit
> >
> https://groups.google.com/d/msgid/kafka-clients/CAMVt_AzWHF3UJ-_d%2Bw_X2C0C%3DEBZyn2%2B049nvB4w7sJbg3jvtQ%40mail.gmail.com
> > <
> https://groups.google.com/d/msgid/kafka-clients/CAMVt_AzWHF3UJ-_d%2Bw_X2C0C%3DEBZyn2%2B049nvB4w7sJbg3jvtQ%40mail.gmail.com?utm_medium=email&utm_source=footer
> >
> > .
> >
> > For more options, visit https://groups.google.com/d/optout.
> >
>
Re: [kafka-clients] Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Joe Stein <jo...@stealth.ly>.
+1 (binding)
artifacts and quick start look good. I ran in some client code, minor edits
from 0-8.2-beta https://github.com/stealthly/scala-kafka/pull/26
On Mon, Jan 26, 2015 at 3:38 AM, Manikumar Reddy <ku...@nmsworks.co.in>
wrote:
> +1 (Non-binding)
> Verified source package, unit tests, release build, topic deletion,
> compaction and random testing
>
> On Mon, Jan 26, 2015 at 6:14 AM, Neha Narkhede <ne...@confluent.io> wrote:
>
>> +1 (binding)
>> Verified keys, quick start, unit tests.
>>
>> On Sat, Jan 24, 2015 at 4:26 PM, Joe Stein <jo...@stealth.ly> wrote:
>>
>> > That makes sense, thanks!
>> >
>> > On Sat, Jan 24, 2015 at 7:00 PM, Jay Kreps <ja...@gmail.com> wrote:
>> >
>> > > But I think the flaw in trying to guess what kind of serializer they
>> will
>> > > use is when we get it wrong. Basically let's say we guess "String".
>> Say
>> > 30%
>> > > of the time we will be right and we will save the two configuration
>> > lines.
>> > > 70% of the time we will be wrong and the user gets a super cryptic
>> > > ClassCastException: "xyz cannot be cast to [B" (because [B is how java
>> > > chooses to display the byte array class just to up the pain), then
>> they
>> > > figure out how to subscribe to our mailing list and email us the
>> cryptic
>> > > exception, then we explain about how we helpfully set these properties
>> > for
>> > > them to save them time. :-)
>> > >
>> > >
>> https://www.google.com/?gws_rd=ssl#q=kafka+classcastexception+%22%5BB%22
>> > >
>> > > I think basically we did this experiment with the old clients and the
>> > > conclusion is that serialization is something you basically have to
>> think
>> > > about to use Kafka and trying to guess just makes things worse.
>> > >
>> > > -Jay
>> > >
>> > > On Sat, Jan 24, 2015 at 2:51 PM, Joe Stein <jo...@stealth.ly>
>> wrote:
>> > >
>> > >> Maybe. I think the StringSerialzer could look more like a typical
>> type
>> > of
>> > >> message. Instead of encoding being a property it would be more
>> > typically
>> > >> just written in the bytes.
>> > >>
>> > >> On Sat, Jan 24, 2015 at 12:12 AM, Jay Kreps <ja...@gmail.com>
>> > wrote:
>> > >>
>> > >> > I don't think so--see if you buy my explanation. We previously
>> > defaulted
>> > >> > to the byte array serializer and it was a source of unending
>> > frustration
>> > >> > and confusion. Since it wasn't a required config people just went
>> > along
>> > >> > plugging in whatever objects they had, and thinking that changing
>> the
>> > >> > parametric types would somehow help. Then they would get a class
>> case
>> > >> > exception and assume our stuff was somehow busted, not realizing we
>> > had
>> > >> > helpfully configured a type different from what they were passing
>> in
>> > >> under
>> > >> > the covers. So I think it is actually good for people to think: how
>> > am I
>> > >> > serializing my data, and getting that exception will make them ask
>> > that
>> > >> > question right?
>> > >> >
>> > >> > -Jay
>> > >> >
>> > >> > On Fri, Jan 23, 2015 at 9:06 PM, Joe Stein <jo...@stealth.ly>
>> > >> wrote:
>> > >> >
>> > >> >> Should value.serializer in the new java producer be defaulted to
>> > >> >> Array[Byte] ?
>> > >> >>
>> > >> >> I was working on testing some upgrade paths and got this
>> > >> >>
>> > >> >> ! return exception in callback when buffer cannot accept
>> message
>> > >> >>
>> > >> >> ConfigException: Missing required configuration
>> > >> "value.serializer"
>> > >> >> which has no default value. (ConfigDef.java:124)
>> > >> >>
>> > >> >>
>> org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:124)
>> > >> >>
>> > >> >>
>> > >> >>
>> > >> >>
>> > >>
>> >
>> org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:48)
>> > >> >>
>> > >> >>
>> > >> >>
>> > >> >>
>> > >>
>> >
>> org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:235)
>> > >> >>
>> > >> >>
>> > >> >>
>> > >> >>
>> > >>
>> >
>> org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:129)
>> > >> >>
>> > >> >>
>> > >> >>
>> > >> >>
>> > >>
>> >
>> ly.stealth.testing.BaseSpec$class.createNewKafkaProducer(BaseSpec.scala:42)
>> > >> >>
>> > >> >>
>> > >>
>> ly.stealth.testing.KafkaSpec.createNewKafkaProducer(KafkaSpec.scala:36)
>> > >> >>
>> > >> >>
>> > >> >>
>> > >> >>
>> > >>
>> >
>> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:175)
>> > >> >>
>> > >> >>
>> > >> >>
>> > >> >>
>> > >>
>> >
>> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:170)
>> > >> >>
>> > >> >>
>> > >> >>
>> > >> >> On Fri, Jan 23, 2015 at 5:55 PM, Jun Rao <ju...@confluent.io>
>> wrote:
>> > >> >>
>> > >> >> > This is a reminder that the deadline for the vote is this
>> Monday,
>> > Jan
>> > >> >> 26,
>> > >> >> > 7pm PT.
>> > >> >> >
>> > >> >> > Thanks,
>> > >> >> >
>> > >> >> > Jun
>> > >> >> >
>> > >> >> > On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io>
>> wrote:
>> > >> >> >
>> > >> >> >> This is the second candidate for release of Apache Kafka
>> 0.8.2.0.
>> > >> There
>> > >> >> >> has been some changes since the 0.8.2 beta release, especially
>> in
>> > >> the
>> > >> >> new
>> > >> >> >> java producer api and jmx mbean names. It would be great if
>> people
>> > >> can
>> > >> >> test
>> > >> >> >> this out thoroughly.
>> > >> >> >>
>> > >> >> >> Release Notes for the 0.8.2.0 release
>> > >> >> >>
>> > >> >> >>
>> > >> >>
>> > >>
>> >
>> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
>> > >> >> >>
>> > >> >> >> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
>> > >> >> >>
>> > >> >> >> Kafka's KEYS file containing PGP keys we use to sign the
>> release:
>> > >> >> >> http://kafka.apache.org/KEYS in addition to the md5, sha1 and
>> > sha2
>> > >> >> >> (SHA256) checksum.
>> > >> >> >>
>> > >> >> >> * Release artifacts to be voted upon (source and binary):
>> > >> >> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
>> > >> >> >>
>> > >> >> >> * Maven artifacts to be voted upon prior to release:
>> > >> >> >> https://repository.apache.org/content/groups/staging/
>> > >> >> >>
>> > >> >> >> * scala-doc
>> > >> >> >>
>> > >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
>> > >> >> >>
>> > >> >> >> * java-doc
>> > >> >> >>
>> > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
>> > >> >> >>
>> > >> >> >> * The tag to be voted upon (off the 0.8.2 branch) is the
>> 0.8.2.0
>> > tag
>> > >> >> >>
>> > >> >> >>
>> > >> >>
>> > >>
>> >
>> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
>> > >> >> >> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
>> > >> >> >>
>> > >> >> >> /*******************************************
>> > >> >> >>
>> > >> >> >> Thanks,
>> > >> >> >>
>> > >> >> >> Jun
>> > >> >> >>
>> > >> >> >>
>> > >> >> > --
>> > >> >> > You received this message because you are subscribed to the
>> Google
>> > >> >> Groups
>> > >> >> > "kafka-clients" group.
>> > >> >> > To unsubscribe from this group and stop receiving emails from
>> it,
>> > >> send
>> > >> >> an
>> > >> >> > email to kafka-clients+unsubscribe@googlegroups.com.
>> > >> >> > To post to this group, send email to
>> > kafka-clients@googlegroups.com.
>> > >> >> > Visit this group at
>> http://groups.google.com/group/kafka-clients.
>> > >> >> > To view this discussion on the web visit
>> > >> >> >
>> > >> >>
>> > >>
>> >
>> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com
>> > >> >> > <
>> > >> >>
>> > >>
>> >
>> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com?utm_medium=email&utm_source=footer
>> > >> >> >
>> > >> >> > .
>> > >> >> >
>> > >> >> > For more options, visit https://groups.google.com/d/optout.
>> > >> >> >
>> > >> >>
>> > >> >
>> > >> > --
>> > >> > You received this message because you are subscribed to the Google
>> > >> Groups
>> > >> > "kafka-clients" group.
>> > >> > To unsubscribe from this group and stop receiving emails from it,
>> send
>> > >> an
>> > >> > email to kafka-clients+unsubscribe@googlegroups.com.
>> > >> > To post to this group, send email to
>> kafka-clients@googlegroups.com.
>> > >> > Visit this group at http://groups.google.com/group/kafka-clients.
>> > >> > To view this discussion on the web visit
>> > >> >
>> > >>
>> >
>> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com
>> > >> > <
>> > >>
>> >
>> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com?utm_medium=email&utm_source=footer
>> > >> >
>> > >> > .
>> > >> >
>> > >> > For more options, visit https://groups.google.com/d/optout.
>> > >> >
>> > >>
>> > >
>> > > --
>> > > You received this message because you are subscribed to the Google
>> Groups
>> > > "kafka-clients" group.
>> > > To unsubscribe from this group and stop receiving emails from it,
>> send an
>> > > email to kafka-clients+unsubscribe@googlegroups.com.
>> > > To post to this group, send email to kafka-clients@googlegroups.com.
>> > > Visit this group at http://groups.google.com/group/kafka-clients.
>> > > To view this discussion on the web visit
>> > >
>> >
>> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJgO6mvJ-y8pe6ik5GuDp%2BvufoJi-U23LqVnbjXWj16JMw%40mail.gmail.com
>> > > <
>> >
>> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJgO6mvJ-y8pe6ik5GuDp%2BvufoJi-U23LqVnbjXWj16JMw%40mail.gmail.com?utm_medium=email&utm_source=footer
>> > >
>> > > .
>> > >
>> > > For more options, visit https://groups.google.com/d/optout.
>> > >
>> >
>>
>>
>>
>> --
>> Thanks,
>> Neha
>>
>
> --
> You received this message because you are subscribed to the Google Groups
> "kafka-clients" group.
> To unsubscribe from this group and stop receiving emails from it, send an
> email to kafka-clients+unsubscribe@googlegroups.com.
> To post to this group, send email to kafka-clients@googlegroups.com.
> Visit this group at http://groups.google.com/group/kafka-clients.
> To view this discussion on the web visit
> https://groups.google.com/d/msgid/kafka-clients/CAMVt_AzWHF3UJ-_d%2Bw_X2C0C%3DEBZyn2%2B049nvB4w7sJbg3jvtQ%40mail.gmail.com
> <https://groups.google.com/d/msgid/kafka-clients/CAMVt_AzWHF3UJ-_d%2Bw_X2C0C%3DEBZyn2%2B049nvB4w7sJbg3jvtQ%40mail.gmail.com?utm_medium=email&utm_source=footer>
> .
>
> For more options, visit https://groups.google.com/d/optout.
>
Re: [kafka-clients] Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Joe Stein <jo...@stealth.ly>.
+1 (binding)
artifacts and quick start look good. I ran in some client code, minor edits
from 0-8.2-beta https://github.com/stealthly/scala-kafka/pull/26
On Mon, Jan 26, 2015 at 3:38 AM, Manikumar Reddy <ku...@nmsworks.co.in>
wrote:
> +1 (Non-binding)
> Verified source package, unit tests, release build, topic deletion,
> compaction and random testing
>
> On Mon, Jan 26, 2015 at 6:14 AM, Neha Narkhede <ne...@confluent.io> wrote:
>
>> +1 (binding)
>> Verified keys, quick start, unit tests.
>>
>> On Sat, Jan 24, 2015 at 4:26 PM, Joe Stein <jo...@stealth.ly> wrote:
>>
>> > That makes sense, thanks!
>> >
>> > On Sat, Jan 24, 2015 at 7:00 PM, Jay Kreps <ja...@gmail.com> wrote:
>> >
>> > > But I think the flaw in trying to guess what kind of serializer they
>> will
>> > > use is when we get it wrong. Basically let's say we guess "String".
>> Say
>> > 30%
>> > > of the time we will be right and we will save the two configuration
>> > lines.
>> > > 70% of the time we will be wrong and the user gets a super cryptic
>> > > ClassCastException: "xyz cannot be cast to [B" (because [B is how java
>> > > chooses to display the byte array class just to up the pain), then
>> they
>> > > figure out how to subscribe to our mailing list and email us the
>> cryptic
>> > > exception, then we explain about how we helpfully set these properties
>> > for
>> > > them to save them time. :-)
>> > >
>> > >
>> https://www.google.com/?gws_rd=ssl#q=kafka+classcastexception+%22%5BB%22
>> > >
>> > > I think basically we did this experiment with the old clients and the
>> > > conclusion is that serialization is something you basically have to
>> think
>> > > about to use Kafka and trying to guess just makes things worse.
>> > >
>> > > -Jay
>> > >
>> > > On Sat, Jan 24, 2015 at 2:51 PM, Joe Stein <jo...@stealth.ly>
>> wrote:
>> > >
>> > >> Maybe. I think the StringSerialzer could look more like a typical
>> type
>> > of
>> > >> message. Instead of encoding being a property it would be more
>> > typically
>> > >> just written in the bytes.
>> > >>
>> > >> On Sat, Jan 24, 2015 at 12:12 AM, Jay Kreps <ja...@gmail.com>
>> > wrote:
>> > >>
>> > >> > I don't think so--see if you buy my explanation. We previously
>> > defaulted
>> > >> > to the byte array serializer and it was a source of unending
>> > frustration
>> > >> > and confusion. Since it wasn't a required config people just went
>> > along
>> > >> > plugging in whatever objects they had, and thinking that changing
>> the
>> > >> > parametric types would somehow help. Then they would get a class
>> case
>> > >> > exception and assume our stuff was somehow busted, not realizing we
>> > had
>> > >> > helpfully configured a type different from what they were passing
>> in
>> > >> under
>> > >> > the covers. So I think it is actually good for people to think: how
>> > am I
>> > >> > serializing my data, and getting that exception will make them ask
>> > that
>> > >> > question right?
>> > >> >
>> > >> > -Jay
>> > >> >
>> > >> > On Fri, Jan 23, 2015 at 9:06 PM, Joe Stein <jo...@stealth.ly>
>> > >> wrote:
>> > >> >
>> > >> >> Should value.serializer in the new java producer be defaulted to
>> > >> >> Array[Byte] ?
>> > >> >>
>> > >> >> I was working on testing some upgrade paths and got this
>> > >> >>
>> > >> >> ! return exception in callback when buffer cannot accept
>> message
>> > >> >>
>> > >> >> ConfigException: Missing required configuration
>> > >> "value.serializer"
>> > >> >> which has no default value. (ConfigDef.java:124)
>> > >> >>
>> > >> >>
>> org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:124)
>> > >> >>
>> > >> >>
>> > >> >>
>> > >> >>
>> > >>
>> >
>> org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:48)
>> > >> >>
>> > >> >>
>> > >> >>
>> > >> >>
>> > >>
>> >
>> org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:235)
>> > >> >>
>> > >> >>
>> > >> >>
>> > >> >>
>> > >>
>> >
>> org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:129)
>> > >> >>
>> > >> >>
>> > >> >>
>> > >> >>
>> > >>
>> >
>> ly.stealth.testing.BaseSpec$class.createNewKafkaProducer(BaseSpec.scala:42)
>> > >> >>
>> > >> >>
>> > >>
>> ly.stealth.testing.KafkaSpec.createNewKafkaProducer(KafkaSpec.scala:36)
>> > >> >>
>> > >> >>
>> > >> >>
>> > >> >>
>> > >>
>> >
>> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:175)
>> > >> >>
>> > >> >>
>> > >> >>
>> > >> >>
>> > >>
>> >
>> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:170)
>> > >> >>
>> > >> >>
>> > >> >>
>> > >> >> On Fri, Jan 23, 2015 at 5:55 PM, Jun Rao <ju...@confluent.io>
>> wrote:
>> > >> >>
>> > >> >> > This is a reminder that the deadline for the vote is this
>> Monday,
>> > Jan
>> > >> >> 26,
>> > >> >> > 7pm PT.
>> > >> >> >
>> > >> >> > Thanks,
>> > >> >> >
>> > >> >> > Jun
>> > >> >> >
>> > >> >> > On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io>
>> wrote:
>> > >> >> >
>> > >> >> >> This is the second candidate for release of Apache Kafka
>> 0.8.2.0.
>> > >> There
>> > >> >> >> has been some changes since the 0.8.2 beta release, especially
>> in
>> > >> the
>> > >> >> new
>> > >> >> >> java producer api and jmx mbean names. It would be great if
>> people
>> > >> can
>> > >> >> test
>> > >> >> >> this out thoroughly.
>> > >> >> >>
>> > >> >> >> Release Notes for the 0.8.2.0 release
>> > >> >> >>
>> > >> >> >>
>> > >> >>
>> > >>
>> >
>> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
>> > >> >> >>
>> > >> >> >> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
>> > >> >> >>
>> > >> >> >> Kafka's KEYS file containing PGP keys we use to sign the
>> release:
>> > >> >> >> http://kafka.apache.org/KEYS in addition to the md5, sha1 and
>> > sha2
>> > >> >> >> (SHA256) checksum.
>> > >> >> >>
>> > >> >> >> * Release artifacts to be voted upon (source and binary):
>> > >> >> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
>> > >> >> >>
>> > >> >> >> * Maven artifacts to be voted upon prior to release:
>> > >> >> >> https://repository.apache.org/content/groups/staging/
>> > >> >> >>
>> > >> >> >> * scala-doc
>> > >> >> >>
>> > >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
>> > >> >> >>
>> > >> >> >> * java-doc
>> > >> >> >>
>> > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
>> > >> >> >>
>> > >> >> >> * The tag to be voted upon (off the 0.8.2 branch) is the
>> 0.8.2.0
>> > tag
>> > >> >> >>
>> > >> >> >>
>> > >> >>
>> > >>
>> >
>> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
>> > >> >> >> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
>> > >> >> >>
>> > >> >> >> /*******************************************
>> > >> >> >>
>> > >> >> >> Thanks,
>> > >> >> >>
>> > >> >> >> Jun
>> > >> >> >>
>> > >> >> >>
>> > >> >> > --
>> > >> >> > You received this message because you are subscribed to the
>> Google
>> > >> >> Groups
>> > >> >> > "kafka-clients" group.
>> > >> >> > To unsubscribe from this group and stop receiving emails from
>> it,
>> > >> send
>> > >> >> an
>> > >> >> > email to kafka-clients+unsubscribe@googlegroups.com.
>> > >> >> > To post to this group, send email to
>> > kafka-clients@googlegroups.com.
>> > >> >> > Visit this group at
>> http://groups.google.com/group/kafka-clients.
>> > >> >> > To view this discussion on the web visit
>> > >> >> >
>> > >> >>
>> > >>
>> >
>> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com
>> > >> >> > <
>> > >> >>
>> > >>
>> >
>> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com?utm_medium=email&utm_source=footer
>> > >> >> >
>> > >> >> > .
>> > >> >> >
>> > >> >> > For more options, visit https://groups.google.com/d/optout.
>> > >> >> >
>> > >> >>
>> > >> >
>> > >> > --
>> > >> > You received this message because you are subscribed to the Google
>> > >> Groups
>> > >> > "kafka-clients" group.
>> > >> > To unsubscribe from this group and stop receiving emails from it,
>> send
>> > >> an
>> > >> > email to kafka-clients+unsubscribe@googlegroups.com.
>> > >> > To post to this group, send email to
>> kafka-clients@googlegroups.com.
>> > >> > Visit this group at http://groups.google.com/group/kafka-clients.
>> > >> > To view this discussion on the web visit
>> > >> >
>> > >>
>> >
>> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com
>> > >> > <
>> > >>
>> >
>> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com?utm_medium=email&utm_source=footer
>> > >> >
>> > >> > .
>> > >> >
>> > >> > For more options, visit https://groups.google.com/d/optout.
>> > >> >
>> > >>
>> > >
>> > > --
>> > > You received this message because you are subscribed to the Google
>> Groups
>> > > "kafka-clients" group.
>> > > To unsubscribe from this group and stop receiving emails from it,
>> send an
>> > > email to kafka-clients+unsubscribe@googlegroups.com.
>> > > To post to this group, send email to kafka-clients@googlegroups.com.
>> > > Visit this group at http://groups.google.com/group/kafka-clients.
>> > > To view this discussion on the web visit
>> > >
>> >
>> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJgO6mvJ-y8pe6ik5GuDp%2BvufoJi-U23LqVnbjXWj16JMw%40mail.gmail.com
>> > > <
>> >
>> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJgO6mvJ-y8pe6ik5GuDp%2BvufoJi-U23LqVnbjXWj16JMw%40mail.gmail.com?utm_medium=email&utm_source=footer
>> > >
>> > > .
>> > >
>> > > For more options, visit https://groups.google.com/d/optout.
>> > >
>> >
>>
>>
>>
>> --
>> Thanks,
>> Neha
>>
>
> --
> You received this message because you are subscribed to the Google Groups
> "kafka-clients" group.
> To unsubscribe from this group and stop receiving emails from it, send an
> email to kafka-clients+unsubscribe@googlegroups.com.
> To post to this group, send email to kafka-clients@googlegroups.com.
> Visit this group at http://groups.google.com/group/kafka-clients.
> To view this discussion on the web visit
> https://groups.google.com/d/msgid/kafka-clients/CAMVt_AzWHF3UJ-_d%2Bw_X2C0C%3DEBZyn2%2B049nvB4w7sJbg3jvtQ%40mail.gmail.com
> <https://groups.google.com/d/msgid/kafka-clients/CAMVt_AzWHF3UJ-_d%2Bw_X2C0C%3DEBZyn2%2B049nvB4w7sJbg3jvtQ%40mail.gmail.com?utm_medium=email&utm_source=footer>
> .
>
> For more options, visit https://groups.google.com/d/optout.
>
Re: [kafka-clients] Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Manikumar Reddy <ku...@nmsworks.co.in>.
+1 (Non-binding)
Verified source package, unit tests, release build, topic deletion,
compaction and random testing
On Mon, Jan 26, 2015 at 6:14 AM, Neha Narkhede <ne...@confluent.io> wrote:
> +1 (binding)
> Verified keys, quick start, unit tests.
>
> On Sat, Jan 24, 2015 at 4:26 PM, Joe Stein <jo...@stealth.ly> wrote:
>
> > That makes sense, thanks!
> >
> > On Sat, Jan 24, 2015 at 7:00 PM, Jay Kreps <ja...@gmail.com> wrote:
> >
> > > But I think the flaw in trying to guess what kind of serializer they
> will
> > > use is when we get it wrong. Basically let's say we guess "String". Say
> > 30%
> > > of the time we will be right and we will save the two configuration
> > lines.
> > > 70% of the time we will be wrong and the user gets a super cryptic
> > > ClassCastException: "xyz cannot be cast to [B" (because [B is how java
> > > chooses to display the byte array class just to up the pain), then they
> > > figure out how to subscribe to our mailing list and email us the
> cryptic
> > > exception, then we explain about how we helpfully set these properties
> > for
> > > them to save them time. :-)
> > >
> > >
> https://www.google.com/?gws_rd=ssl#q=kafka+classcastexception+%22%5BB%22
> > >
> > > I think basically we did this experiment with the old clients and the
> > > conclusion is that serialization is something you basically have to
> think
> > > about to use Kafka and trying to guess just makes things worse.
> > >
> > > -Jay
> > >
> > > On Sat, Jan 24, 2015 at 2:51 PM, Joe Stein <jo...@stealth.ly>
> wrote:
> > >
> > >> Maybe. I think the StringSerialzer could look more like a typical type
> > of
> > >> message. Instead of encoding being a property it would be more
> > typically
> > >> just written in the bytes.
> > >>
> > >> On Sat, Jan 24, 2015 at 12:12 AM, Jay Kreps <ja...@gmail.com>
> > wrote:
> > >>
> > >> > I don't think so--see if you buy my explanation. We previously
> > defaulted
> > >> > to the byte array serializer and it was a source of unending
> > frustration
> > >> > and confusion. Since it wasn't a required config people just went
> > along
> > >> > plugging in whatever objects they had, and thinking that changing
> the
> > >> > parametric types would somehow help. Then they would get a class
> case
> > >> > exception and assume our stuff was somehow busted, not realizing we
> > had
> > >> > helpfully configured a type different from what they were passing in
> > >> under
> > >> > the covers. So I think it is actually good for people to think: how
> > am I
> > >> > serializing my data, and getting that exception will make them ask
> > that
> > >> > question right?
> > >> >
> > >> > -Jay
> > >> >
> > >> > On Fri, Jan 23, 2015 at 9:06 PM, Joe Stein <jo...@stealth.ly>
> > >> wrote:
> > >> >
> > >> >> Should value.serializer in the new java producer be defaulted to
> > >> >> Array[Byte] ?
> > >> >>
> > >> >> I was working on testing some upgrade paths and got this
> > >> >>
> > >> >> ! return exception in callback when buffer cannot accept
> message
> > >> >>
> > >> >> ConfigException: Missing required configuration
> > >> "value.serializer"
> > >> >> which has no default value. (ConfigDef.java:124)
> > >> >>
> > >> >>
> org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:124)
> > >> >>
> > >> >>
> > >> >>
> > >> >>
> > >>
> >
> org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:48)
> > >> >>
> > >> >>
> > >> >>
> > >> >>
> > >>
> >
> org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:235)
> > >> >>
> > >> >>
> > >> >>
> > >> >>
> > >>
> >
> org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:129)
> > >> >>
> > >> >>
> > >> >>
> > >> >>
> > >>
> >
> ly.stealth.testing.BaseSpec$class.createNewKafkaProducer(BaseSpec.scala:42)
> > >> >>
> > >> >>
> > >>
> ly.stealth.testing.KafkaSpec.createNewKafkaProducer(KafkaSpec.scala:36)
> > >> >>
> > >> >>
> > >> >>
> > >> >>
> > >>
> >
> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:175)
> > >> >>
> > >> >>
> > >> >>
> > >> >>
> > >>
> >
> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:170)
> > >> >>
> > >> >>
> > >> >>
> > >> >> On Fri, Jan 23, 2015 at 5:55 PM, Jun Rao <ju...@confluent.io> wrote:
> > >> >>
> > >> >> > This is a reminder that the deadline for the vote is this Monday,
> > Jan
> > >> >> 26,
> > >> >> > 7pm PT.
> > >> >> >
> > >> >> > Thanks,
> > >> >> >
> > >> >> > Jun
> > >> >> >
> > >> >> > On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io>
> wrote:
> > >> >> >
> > >> >> >> This is the second candidate for release of Apache Kafka
> 0.8.2.0.
> > >> There
> > >> >> >> has been some changes since the 0.8.2 beta release, especially
> in
> > >> the
> > >> >> new
> > >> >> >> java producer api and jmx mbean names. It would be great if
> people
> > >> can
> > >> >> test
> > >> >> >> this out thoroughly.
> > >> >> >>
> > >> >> >> Release Notes for the 0.8.2.0 release
> > >> >> >>
> > >> >> >>
> > >> >>
> > >>
> >
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
> > >> >> >>
> > >> >> >> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
> > >> >> >>
> > >> >> >> Kafka's KEYS file containing PGP keys we use to sign the
> release:
> > >> >> >> http://kafka.apache.org/KEYS in addition to the md5, sha1 and
> > sha2
> > >> >> >> (SHA256) checksum.
> > >> >> >>
> > >> >> >> * Release artifacts to be voted upon (source and binary):
> > >> >> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
> > >> >> >>
> > >> >> >> * Maven artifacts to be voted upon prior to release:
> > >> >> >> https://repository.apache.org/content/groups/staging/
> > >> >> >>
> > >> >> >> * scala-doc
> > >> >> >>
> > >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
> > >> >> >>
> > >> >> >> * java-doc
> > >> >> >>
> > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
> > >> >> >>
> > >> >> >> * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0
> > tag
> > >> >> >>
> > >> >> >>
> > >> >>
> > >>
> >
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> > >> >> >> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
> > >> >> >>
> > >> >> >> /*******************************************
> > >> >> >>
> > >> >> >> Thanks,
> > >> >> >>
> > >> >> >> Jun
> > >> >> >>
> > >> >> >>
> > >> >> > --
> > >> >> > You received this message because you are subscribed to the
> Google
> > >> >> Groups
> > >> >> > "kafka-clients" group.
> > >> >> > To unsubscribe from this group and stop receiving emails from it,
> > >> send
> > >> >> an
> > >> >> > email to kafka-clients+unsubscribe@googlegroups.com.
> > >> >> > To post to this group, send email to
> > kafka-clients@googlegroups.com.
> > >> >> > Visit this group at http://groups.google.com/group/kafka-clients
> .
> > >> >> > To view this discussion on the web visit
> > >> >> >
> > >> >>
> > >>
> >
> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com
> > >> >> > <
> > >> >>
> > >>
> >
> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com?utm_medium=email&utm_source=footer
> > >> >> >
> > >> >> > .
> > >> >> >
> > >> >> > For more options, visit https://groups.google.com/d/optout.
> > >> >> >
> > >> >>
> > >> >
> > >> > --
> > >> > You received this message because you are subscribed to the Google
> > >> Groups
> > >> > "kafka-clients" group.
> > >> > To unsubscribe from this group and stop receiving emails from it,
> send
> > >> an
> > >> > email to kafka-clients+unsubscribe@googlegroups.com.
> > >> > To post to this group, send email to kafka-clients@googlegroups.com
> .
> > >> > Visit this group at http://groups.google.com/group/kafka-clients.
> > >> > To view this discussion on the web visit
> > >> >
> > >>
> >
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com
> > >> > <
> > >>
> >
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com?utm_medium=email&utm_source=footer
> > >> >
> > >> > .
> > >> >
> > >> > For more options, visit https://groups.google.com/d/optout.
> > >> >
> > >>
> > >
> > > --
> > > You received this message because you are subscribed to the Google
> Groups
> > > "kafka-clients" group.
> > > To unsubscribe from this group and stop receiving emails from it, send
> an
> > > email to kafka-clients+unsubscribe@googlegroups.com.
> > > To post to this group, send email to kafka-clients@googlegroups.com.
> > > Visit this group at http://groups.google.com/group/kafka-clients.
> > > To view this discussion on the web visit
> > >
> >
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJgO6mvJ-y8pe6ik5GuDp%2BvufoJi-U23LqVnbjXWj16JMw%40mail.gmail.com
> > > <
> >
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJgO6mvJ-y8pe6ik5GuDp%2BvufoJi-U23LqVnbjXWj16JMw%40mail.gmail.com?utm_medium=email&utm_source=footer
> > >
> > > .
> > >
> > > For more options, visit https://groups.google.com/d/optout.
> > >
> >
>
>
>
> --
> Thanks,
> Neha
>
Re: [kafka-clients] Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Manikumar Reddy <ku...@nmsworks.co.in>.
+1 (Non-binding)
Verified source package, unit tests, release build, topic deletion,
compaction and random testing
On Mon, Jan 26, 2015 at 6:14 AM, Neha Narkhede <ne...@confluent.io> wrote:
> +1 (binding)
> Verified keys, quick start, unit tests.
>
> On Sat, Jan 24, 2015 at 4:26 PM, Joe Stein <jo...@stealth.ly> wrote:
>
> > That makes sense, thanks!
> >
> > On Sat, Jan 24, 2015 at 7:00 PM, Jay Kreps <ja...@gmail.com> wrote:
> >
> > > But I think the flaw in trying to guess what kind of serializer they
> will
> > > use is when we get it wrong. Basically let's say we guess "String". Say
> > 30%
> > > of the time we will be right and we will save the two configuration
> > lines.
> > > 70% of the time we will be wrong and the user gets a super cryptic
> > > ClassCastException: "xyz cannot be cast to [B" (because [B is how java
> > > chooses to display the byte array class just to up the pain), then they
> > > figure out how to subscribe to our mailing list and email us the
> cryptic
> > > exception, then we explain about how we helpfully set these properties
> > for
> > > them to save them time. :-)
> > >
> > >
> https://www.google.com/?gws_rd=ssl#q=kafka+classcastexception+%22%5BB%22
> > >
> > > I think basically we did this experiment with the old clients and the
> > > conclusion is that serialization is something you basically have to
> think
> > > about to use Kafka and trying to guess just makes things worse.
> > >
> > > -Jay
> > >
> > > On Sat, Jan 24, 2015 at 2:51 PM, Joe Stein <jo...@stealth.ly>
> wrote:
> > >
> > >> Maybe. I think the StringSerialzer could look more like a typical type
> > of
> > >> message. Instead of encoding being a property it would be more
> > typically
> > >> just written in the bytes.
> > >>
> > >> On Sat, Jan 24, 2015 at 12:12 AM, Jay Kreps <ja...@gmail.com>
> > wrote:
> > >>
> > >> > I don't think so--see if you buy my explanation. We previously
> > defaulted
> > >> > to the byte array serializer and it was a source of unending
> > frustration
> > >> > and confusion. Since it wasn't a required config people just went
> > along
> > >> > plugging in whatever objects they had, and thinking that changing
> the
> > >> > parametric types would somehow help. Then they would get a class
> case
> > >> > exception and assume our stuff was somehow busted, not realizing we
> > had
> > >> > helpfully configured a type different from what they were passing in
> > >> under
> > >> > the covers. So I think it is actually good for people to think: how
> > am I
> > >> > serializing my data, and getting that exception will make them ask
> > that
> > >> > question right?
> > >> >
> > >> > -Jay
> > >> >
> > >> > On Fri, Jan 23, 2015 at 9:06 PM, Joe Stein <jo...@stealth.ly>
> > >> wrote:
> > >> >
> > >> >> Should value.serializer in the new java producer be defaulted to
> > >> >> Array[Byte] ?
> > >> >>
> > >> >> I was working on testing some upgrade paths and got this
> > >> >>
> > >> >> ! return exception in callback when buffer cannot accept
> message
> > >> >>
> > >> >> ConfigException: Missing required configuration
> > >> "value.serializer"
> > >> >> which has no default value. (ConfigDef.java:124)
> > >> >>
> > >> >>
> org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:124)
> > >> >>
> > >> >>
> > >> >>
> > >> >>
> > >>
> >
> org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:48)
> > >> >>
> > >> >>
> > >> >>
> > >> >>
> > >>
> >
> org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:235)
> > >> >>
> > >> >>
> > >> >>
> > >> >>
> > >>
> >
> org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:129)
> > >> >>
> > >> >>
> > >> >>
> > >> >>
> > >>
> >
> ly.stealth.testing.BaseSpec$class.createNewKafkaProducer(BaseSpec.scala:42)
> > >> >>
> > >> >>
> > >>
> ly.stealth.testing.KafkaSpec.createNewKafkaProducer(KafkaSpec.scala:36)
> > >> >>
> > >> >>
> > >> >>
> > >> >>
> > >>
> >
> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:175)
> > >> >>
> > >> >>
> > >> >>
> > >> >>
> > >>
> >
> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:170)
> > >> >>
> > >> >>
> > >> >>
> > >> >> On Fri, Jan 23, 2015 at 5:55 PM, Jun Rao <ju...@confluent.io> wrote:
> > >> >>
> > >> >> > This is a reminder that the deadline for the vote is this Monday,
> > Jan
> > >> >> 26,
> > >> >> > 7pm PT.
> > >> >> >
> > >> >> > Thanks,
> > >> >> >
> > >> >> > Jun
> > >> >> >
> > >> >> > On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io>
> wrote:
> > >> >> >
> > >> >> >> This is the second candidate for release of Apache Kafka
> 0.8.2.0.
> > >> There
> > >> >> >> has been some changes since the 0.8.2 beta release, especially
> in
> > >> the
> > >> >> new
> > >> >> >> java producer api and jmx mbean names. It would be great if
> people
> > >> can
> > >> >> test
> > >> >> >> this out thoroughly.
> > >> >> >>
> > >> >> >> Release Notes for the 0.8.2.0 release
> > >> >> >>
> > >> >> >>
> > >> >>
> > >>
> >
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
> > >> >> >>
> > >> >> >> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
> > >> >> >>
> > >> >> >> Kafka's KEYS file containing PGP keys we use to sign the
> release:
> > >> >> >> http://kafka.apache.org/KEYS in addition to the md5, sha1 and
> > sha2
> > >> >> >> (SHA256) checksum.
> > >> >> >>
> > >> >> >> * Release artifacts to be voted upon (source and binary):
> > >> >> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
> > >> >> >>
> > >> >> >> * Maven artifacts to be voted upon prior to release:
> > >> >> >> https://repository.apache.org/content/groups/staging/
> > >> >> >>
> > >> >> >> * scala-doc
> > >> >> >>
> > >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
> > >> >> >>
> > >> >> >> * java-doc
> > >> >> >>
> > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
> > >> >> >>
> > >> >> >> * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0
> > tag
> > >> >> >>
> > >> >> >>
> > >> >>
> > >>
> >
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> > >> >> >> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
> > >> >> >>
> > >> >> >> /*******************************************
> > >> >> >>
> > >> >> >> Thanks,
> > >> >> >>
> > >> >> >> Jun
> > >> >> >>
> > >> >> >>
> > >> >> > --
> > >> >> > You received this message because you are subscribed to the
> Google
> > >> >> Groups
> > >> >> > "kafka-clients" group.
> > >> >> > To unsubscribe from this group and stop receiving emails from it,
> > >> send
> > >> >> an
> > >> >> > email to kafka-clients+unsubscribe@googlegroups.com.
> > >> >> > To post to this group, send email to
> > kafka-clients@googlegroups.com.
> > >> >> > Visit this group at http://groups.google.com/group/kafka-clients
> .
> > >> >> > To view this discussion on the web visit
> > >> >> >
> > >> >>
> > >>
> >
> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com
> > >> >> > <
> > >> >>
> > >>
> >
> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com?utm_medium=email&utm_source=footer
> > >> >> >
> > >> >> > .
> > >> >> >
> > >> >> > For more options, visit https://groups.google.com/d/optout.
> > >> >> >
> > >> >>
> > >> >
> > >> > --
> > >> > You received this message because you are subscribed to the Google
> > >> Groups
> > >> > "kafka-clients" group.
> > >> > To unsubscribe from this group and stop receiving emails from it,
> send
> > >> an
> > >> > email to kafka-clients+unsubscribe@googlegroups.com.
> > >> > To post to this group, send email to kafka-clients@googlegroups.com
> .
> > >> > Visit this group at http://groups.google.com/group/kafka-clients.
> > >> > To view this discussion on the web visit
> > >> >
> > >>
> >
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com
> > >> > <
> > >>
> >
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com?utm_medium=email&utm_source=footer
> > >> >
> > >> > .
> > >> >
> > >> > For more options, visit https://groups.google.com/d/optout.
> > >> >
> > >>
> > >
> > > --
> > > You received this message because you are subscribed to the Google
> Groups
> > > "kafka-clients" group.
> > > To unsubscribe from this group and stop receiving emails from it, send
> an
> > > email to kafka-clients+unsubscribe@googlegroups.com.
> > > To post to this group, send email to kafka-clients@googlegroups.com.
> > > Visit this group at http://groups.google.com/group/kafka-clients.
> > > To view this discussion on the web visit
> > >
> >
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJgO6mvJ-y8pe6ik5GuDp%2BvufoJi-U23LqVnbjXWj16JMw%40mail.gmail.com
> > > <
> >
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJgO6mvJ-y8pe6ik5GuDp%2BvufoJi-U23LqVnbjXWj16JMw%40mail.gmail.com?utm_medium=email&utm_source=footer
> > >
> > > .
> > >
> > > For more options, visit https://groups.google.com/d/optout.
> > >
> >
>
>
>
> --
> Thanks,
> Neha
>
Re: [kafka-clients] Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Neha Narkhede <ne...@confluent.io>.
+1 (binding)
Verified keys, quick start, unit tests.
On Sat, Jan 24, 2015 at 4:26 PM, Joe Stein <jo...@stealth.ly> wrote:
> That makes sense, thanks!
>
> On Sat, Jan 24, 2015 at 7:00 PM, Jay Kreps <ja...@gmail.com> wrote:
>
> > But I think the flaw in trying to guess what kind of serializer they will
> > use is when we get it wrong. Basically let's say we guess "String". Say
> 30%
> > of the time we will be right and we will save the two configuration
> lines.
> > 70% of the time we will be wrong and the user gets a super cryptic
> > ClassCastException: "xyz cannot be cast to [B" (because [B is how java
> > chooses to display the byte array class just to up the pain), then they
> > figure out how to subscribe to our mailing list and email us the cryptic
> > exception, then we explain about how we helpfully set these properties
> for
> > them to save them time. :-)
> >
> > https://www.google.com/?gws_rd=ssl#q=kafka+classcastexception+%22%5BB%22
> >
> > I think basically we did this experiment with the old clients and the
> > conclusion is that serialization is something you basically have to think
> > about to use Kafka and trying to guess just makes things worse.
> >
> > -Jay
> >
> > On Sat, Jan 24, 2015 at 2:51 PM, Joe Stein <jo...@stealth.ly> wrote:
> >
> >> Maybe. I think the StringSerialzer could look more like a typical type
> of
> >> message. Instead of encoding being a property it would be more
> typically
> >> just written in the bytes.
> >>
> >> On Sat, Jan 24, 2015 at 12:12 AM, Jay Kreps <ja...@gmail.com>
> wrote:
> >>
> >> > I don't think so--see if you buy my explanation. We previously
> defaulted
> >> > to the byte array serializer and it was a source of unending
> frustration
> >> > and confusion. Since it wasn't a required config people just went
> along
> >> > plugging in whatever objects they had, and thinking that changing the
> >> > parametric types would somehow help. Then they would get a class case
> >> > exception and assume our stuff was somehow busted, not realizing we
> had
> >> > helpfully configured a type different from what they were passing in
> >> under
> >> > the covers. So I think it is actually good for people to think: how
> am I
> >> > serializing my data, and getting that exception will make them ask
> that
> >> > question right?
> >> >
> >> > -Jay
> >> >
> >> > On Fri, Jan 23, 2015 at 9:06 PM, Joe Stein <jo...@stealth.ly>
> >> wrote:
> >> >
> >> >> Should value.serializer in the new java producer be defaulted to
> >> >> Array[Byte] ?
> >> >>
> >> >> I was working on testing some upgrade paths and got this
> >> >>
> >> >> ! return exception in callback when buffer cannot accept message
> >> >>
> >> >> ConfigException: Missing required configuration
> >> "value.serializer"
> >> >> which has no default value. (ConfigDef.java:124)
> >> >>
> >> >> org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:124)
> >> >>
> >> >>
> >> >>
> >> >>
> >>
> org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:48)
> >> >>
> >> >>
> >> >>
> >> >>
> >>
> org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:235)
> >> >>
> >> >>
> >> >>
> >> >>
> >>
> org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:129)
> >> >>
> >> >>
> >> >>
> >> >>
> >>
> ly.stealth.testing.BaseSpec$class.createNewKafkaProducer(BaseSpec.scala:42)
> >> >>
> >> >>
> >> ly.stealth.testing.KafkaSpec.createNewKafkaProducer(KafkaSpec.scala:36)
> >> >>
> >> >>
> >> >>
> >> >>
> >>
> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:175)
> >> >>
> >> >>
> >> >>
> >> >>
> >>
> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:170)
> >> >>
> >> >>
> >> >>
> >> >> On Fri, Jan 23, 2015 at 5:55 PM, Jun Rao <ju...@confluent.io> wrote:
> >> >>
> >> >> > This is a reminder that the deadline for the vote is this Monday,
> Jan
> >> >> 26,
> >> >> > 7pm PT.
> >> >> >
> >> >> > Thanks,
> >> >> >
> >> >> > Jun
> >> >> >
> >> >> > On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io> wrote:
> >> >> >
> >> >> >> This is the second candidate for release of Apache Kafka 0.8.2.0.
> >> There
> >> >> >> has been some changes since the 0.8.2 beta release, especially in
> >> the
> >> >> new
> >> >> >> java producer api and jmx mbean names. It would be great if people
> >> can
> >> >> test
> >> >> >> this out thoroughly.
> >> >> >>
> >> >> >> Release Notes for the 0.8.2.0 release
> >> >> >>
> >> >> >>
> >> >>
> >>
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
> >> >> >>
> >> >> >> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
> >> >> >>
> >> >> >> Kafka's KEYS file containing PGP keys we use to sign the release:
> >> >> >> http://kafka.apache.org/KEYS in addition to the md5, sha1 and
> sha2
> >> >> >> (SHA256) checksum.
> >> >> >>
> >> >> >> * Release artifacts to be voted upon (source and binary):
> >> >> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
> >> >> >>
> >> >> >> * Maven artifacts to be voted upon prior to release:
> >> >> >> https://repository.apache.org/content/groups/staging/
> >> >> >>
> >> >> >> * scala-doc
> >> >> >>
> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
> >> >> >>
> >> >> >> * java-doc
> >> >> >>
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
> >> >> >>
> >> >> >> * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0
> tag
> >> >> >>
> >> >> >>
> >> >>
> >>
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> >> >> >> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
> >> >> >>
> >> >> >> /*******************************************
> >> >> >>
> >> >> >> Thanks,
> >> >> >>
> >> >> >> Jun
> >> >> >>
> >> >> >>
> >> >> > --
> >> >> > You received this message because you are subscribed to the Google
> >> >> Groups
> >> >> > "kafka-clients" group.
> >> >> > To unsubscribe from this group and stop receiving emails from it,
> >> send
> >> >> an
> >> >> > email to kafka-clients+unsubscribe@googlegroups.com.
> >> >> > To post to this group, send email to
> kafka-clients@googlegroups.com.
> >> >> > Visit this group at http://groups.google.com/group/kafka-clients.
> >> >> > To view this discussion on the web visit
> >> >> >
> >> >>
> >>
> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com
> >> >> > <
> >> >>
> >>
> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com?utm_medium=email&utm_source=footer
> >> >> >
> >> >> > .
> >> >> >
> >> >> > For more options, visit https://groups.google.com/d/optout.
> >> >> >
> >> >>
> >> >
> >> > --
> >> > You received this message because you are subscribed to the Google
> >> Groups
> >> > "kafka-clients" group.
> >> > To unsubscribe from this group and stop receiving emails from it, send
> >> an
> >> > email to kafka-clients+unsubscribe@googlegroups.com.
> >> > To post to this group, send email to kafka-clients@googlegroups.com.
> >> > Visit this group at http://groups.google.com/group/kafka-clients.
> >> > To view this discussion on the web visit
> >> >
> >>
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com
> >> > <
> >>
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com?utm_medium=email&utm_source=footer
> >> >
> >> > .
> >> >
> >> > For more options, visit https://groups.google.com/d/optout.
> >> >
> >>
> >
> > --
> > You received this message because you are subscribed to the Google Groups
> > "kafka-clients" group.
> > To unsubscribe from this group and stop receiving emails from it, send an
> > email to kafka-clients+unsubscribe@googlegroups.com.
> > To post to this group, send email to kafka-clients@googlegroups.com.
> > Visit this group at http://groups.google.com/group/kafka-clients.
> > To view this discussion on the web visit
> >
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJgO6mvJ-y8pe6ik5GuDp%2BvufoJi-U23LqVnbjXWj16JMw%40mail.gmail.com
> > <
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJgO6mvJ-y8pe6ik5GuDp%2BvufoJi-U23LqVnbjXWj16JMw%40mail.gmail.com?utm_medium=email&utm_source=footer
> >
> > .
> >
> > For more options, visit https://groups.google.com/d/optout.
> >
>
--
Thanks,
Neha
Re: [kafka-clients] Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Neha Narkhede <ne...@confluent.io>.
+1 (binding)
Verified keys, quick start, unit tests.
On Sat, Jan 24, 2015 at 4:26 PM, Joe Stein <jo...@stealth.ly> wrote:
> That makes sense, thanks!
>
> On Sat, Jan 24, 2015 at 7:00 PM, Jay Kreps <ja...@gmail.com> wrote:
>
> > But I think the flaw in trying to guess what kind of serializer they will
> > use is when we get it wrong. Basically let's say we guess "String". Say
> 30%
> > of the time we will be right and we will save the two configuration
> lines.
> > 70% of the time we will be wrong and the user gets a super cryptic
> > ClassCastException: "xyz cannot be cast to [B" (because [B is how java
> > chooses to display the byte array class just to up the pain), then they
> > figure out how to subscribe to our mailing list and email us the cryptic
> > exception, then we explain about how we helpfully set these properties
> for
> > them to save them time. :-)
> >
> > https://www.google.com/?gws_rd=ssl#q=kafka+classcastexception+%22%5BB%22
> >
> > I think basically we did this experiment with the old clients and the
> > conclusion is that serialization is something you basically have to think
> > about to use Kafka and trying to guess just makes things worse.
> >
> > -Jay
> >
> > On Sat, Jan 24, 2015 at 2:51 PM, Joe Stein <jo...@stealth.ly> wrote:
> >
> >> Maybe. I think the StringSerialzer could look more like a typical type
> of
> >> message. Instead of encoding being a property it would be more
> typically
> >> just written in the bytes.
> >>
> >> On Sat, Jan 24, 2015 at 12:12 AM, Jay Kreps <ja...@gmail.com>
> wrote:
> >>
> >> > I don't think so--see if you buy my explanation. We previously
> defaulted
> >> > to the byte array serializer and it was a source of unending
> frustration
> >> > and confusion. Since it wasn't a required config people just went
> along
> >> > plugging in whatever objects they had, and thinking that changing the
> >> > parametric types would somehow help. Then they would get a class case
> >> > exception and assume our stuff was somehow busted, not realizing we
> had
> >> > helpfully configured a type different from what they were passing in
> >> under
> >> > the covers. So I think it is actually good for people to think: how
> am I
> >> > serializing my data, and getting that exception will make them ask
> that
> >> > question right?
> >> >
> >> > -Jay
> >> >
> >> > On Fri, Jan 23, 2015 at 9:06 PM, Joe Stein <jo...@stealth.ly>
> >> wrote:
> >> >
> >> >> Should value.serializer in the new java producer be defaulted to
> >> >> Array[Byte] ?
> >> >>
> >> >> I was working on testing some upgrade paths and got this
> >> >>
> >> >> ! return exception in callback when buffer cannot accept message
> >> >>
> >> >> ConfigException: Missing required configuration
> >> "value.serializer"
> >> >> which has no default value. (ConfigDef.java:124)
> >> >>
> >> >> org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:124)
> >> >>
> >> >>
> >> >>
> >> >>
> >>
> org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:48)
> >> >>
> >> >>
> >> >>
> >> >>
> >>
> org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:235)
> >> >>
> >> >>
> >> >>
> >> >>
> >>
> org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:129)
> >> >>
> >> >>
> >> >>
> >> >>
> >>
> ly.stealth.testing.BaseSpec$class.createNewKafkaProducer(BaseSpec.scala:42)
> >> >>
> >> >>
> >> ly.stealth.testing.KafkaSpec.createNewKafkaProducer(KafkaSpec.scala:36)
> >> >>
> >> >>
> >> >>
> >> >>
> >>
> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:175)
> >> >>
> >> >>
> >> >>
> >> >>
> >>
> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:170)
> >> >>
> >> >>
> >> >>
> >> >> On Fri, Jan 23, 2015 at 5:55 PM, Jun Rao <ju...@confluent.io> wrote:
> >> >>
> >> >> > This is a reminder that the deadline for the vote is this Monday,
> Jan
> >> >> 26,
> >> >> > 7pm PT.
> >> >> >
> >> >> > Thanks,
> >> >> >
> >> >> > Jun
> >> >> >
> >> >> > On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io> wrote:
> >> >> >
> >> >> >> This is the second candidate for release of Apache Kafka 0.8.2.0.
> >> There
> >> >> >> has been some changes since the 0.8.2 beta release, especially in
> >> the
> >> >> new
> >> >> >> java producer api and jmx mbean names. It would be great if people
> >> can
> >> >> test
> >> >> >> this out thoroughly.
> >> >> >>
> >> >> >> Release Notes for the 0.8.2.0 release
> >> >> >>
> >> >> >>
> >> >>
> >>
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
> >> >> >>
> >> >> >> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
> >> >> >>
> >> >> >> Kafka's KEYS file containing PGP keys we use to sign the release:
> >> >> >> http://kafka.apache.org/KEYS in addition to the md5, sha1 and
> sha2
> >> >> >> (SHA256) checksum.
> >> >> >>
> >> >> >> * Release artifacts to be voted upon (source and binary):
> >> >> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
> >> >> >>
> >> >> >> * Maven artifacts to be voted upon prior to release:
> >> >> >> https://repository.apache.org/content/groups/staging/
> >> >> >>
> >> >> >> * scala-doc
> >> >> >>
> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
> >> >> >>
> >> >> >> * java-doc
> >> >> >>
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
> >> >> >>
> >> >> >> * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0
> tag
> >> >> >>
> >> >> >>
> >> >>
> >>
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> >> >> >> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
> >> >> >>
> >> >> >> /*******************************************
> >> >> >>
> >> >> >> Thanks,
> >> >> >>
> >> >> >> Jun
> >> >> >>
> >> >> >>
> >> >> > --
> >> >> > You received this message because you are subscribed to the Google
> >> >> Groups
> >> >> > "kafka-clients" group.
> >> >> > To unsubscribe from this group and stop receiving emails from it,
> >> send
> >> >> an
> >> >> > email to kafka-clients+unsubscribe@googlegroups.com.
> >> >> > To post to this group, send email to
> kafka-clients@googlegroups.com.
> >> >> > Visit this group at http://groups.google.com/group/kafka-clients.
> >> >> > To view this discussion on the web visit
> >> >> >
> >> >>
> >>
> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com
> >> >> > <
> >> >>
> >>
> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com?utm_medium=email&utm_source=footer
> >> >> >
> >> >> > .
> >> >> >
> >> >> > For more options, visit https://groups.google.com/d/optout.
> >> >> >
> >> >>
> >> >
> >> > --
> >> > You received this message because you are subscribed to the Google
> >> Groups
> >> > "kafka-clients" group.
> >> > To unsubscribe from this group and stop receiving emails from it, send
> >> an
> >> > email to kafka-clients+unsubscribe@googlegroups.com.
> >> > To post to this group, send email to kafka-clients@googlegroups.com.
> >> > Visit this group at http://groups.google.com/group/kafka-clients.
> >> > To view this discussion on the web visit
> >> >
> >>
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com
> >> > <
> >>
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com?utm_medium=email&utm_source=footer
> >> >
> >> > .
> >> >
> >> > For more options, visit https://groups.google.com/d/optout.
> >> >
> >>
> >
> > --
> > You received this message because you are subscribed to the Google Groups
> > "kafka-clients" group.
> > To unsubscribe from this group and stop receiving emails from it, send an
> > email to kafka-clients+unsubscribe@googlegroups.com.
> > To post to this group, send email to kafka-clients@googlegroups.com.
> > Visit this group at http://groups.google.com/group/kafka-clients.
> > To view this discussion on the web visit
> >
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJgO6mvJ-y8pe6ik5GuDp%2BvufoJi-U23LqVnbjXWj16JMw%40mail.gmail.com
> > <
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJgO6mvJ-y8pe6ik5GuDp%2BvufoJi-U23LqVnbjXWj16JMw%40mail.gmail.com?utm_medium=email&utm_source=footer
> >
> > .
> >
> > For more options, visit https://groups.google.com/d/optout.
> >
>
--
Thanks,
Neha
Re: [kafka-clients] Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Joe Stein <jo...@stealth.ly>.
That makes sense, thanks!
On Sat, Jan 24, 2015 at 7:00 PM, Jay Kreps <ja...@gmail.com> wrote:
> But I think the flaw in trying to guess what kind of serializer they will
> use is when we get it wrong. Basically let's say we guess "String". Say 30%
> of the time we will be right and we will save the two configuration lines.
> 70% of the time we will be wrong and the user gets a super cryptic
> ClassCastException: "xyz cannot be cast to [B" (because [B is how java
> chooses to display the byte array class just to up the pain), then they
> figure out how to subscribe to our mailing list and email us the cryptic
> exception, then we explain about how we helpfully set these properties for
> them to save them time. :-)
>
> https://www.google.com/?gws_rd=ssl#q=kafka+classcastexception+%22%5BB%22
>
> I think basically we did this experiment with the old clients and the
> conclusion is that serialization is something you basically have to think
> about to use Kafka and trying to guess just makes things worse.
>
> -Jay
>
> On Sat, Jan 24, 2015 at 2:51 PM, Joe Stein <jo...@stealth.ly> wrote:
>
>> Maybe. I think the StringSerialzer could look more like a typical type of
>> message. Instead of encoding being a property it would be more typically
>> just written in the bytes.
>>
>> On Sat, Jan 24, 2015 at 12:12 AM, Jay Kreps <ja...@gmail.com> wrote:
>>
>> > I don't think so--see if you buy my explanation. We previously defaulted
>> > to the byte array serializer and it was a source of unending frustration
>> > and confusion. Since it wasn't a required config people just went along
>> > plugging in whatever objects they had, and thinking that changing the
>> > parametric types would somehow help. Then they would get a class case
>> > exception and assume our stuff was somehow busted, not realizing we had
>> > helpfully configured a type different from what they were passing in
>> under
>> > the covers. So I think it is actually good for people to think: how am I
>> > serializing my data, and getting that exception will make them ask that
>> > question right?
>> >
>> > -Jay
>> >
>> > On Fri, Jan 23, 2015 at 9:06 PM, Joe Stein <jo...@stealth.ly>
>> wrote:
>> >
>> >> Should value.serializer in the new java producer be defaulted to
>> >> Array[Byte] ?
>> >>
>> >> I was working on testing some upgrade paths and got this
>> >>
>> >> ! return exception in callback when buffer cannot accept message
>> >>
>> >> ConfigException: Missing required configuration
>> "value.serializer"
>> >> which has no default value. (ConfigDef.java:124)
>> >>
>> >> org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:124)
>> >>
>> >>
>> >>
>> >>
>> org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:48)
>> >>
>> >>
>> >>
>> >>
>> org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:235)
>> >>
>> >>
>> >>
>> >>
>> org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:129)
>> >>
>> >>
>> >>
>> >>
>> ly.stealth.testing.BaseSpec$class.createNewKafkaProducer(BaseSpec.scala:42)
>> >>
>> >>
>> ly.stealth.testing.KafkaSpec.createNewKafkaProducer(KafkaSpec.scala:36)
>> >>
>> >>
>> >>
>> >>
>> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:175)
>> >>
>> >>
>> >>
>> >>
>> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:170)
>> >>
>> >>
>> >>
>> >> On Fri, Jan 23, 2015 at 5:55 PM, Jun Rao <ju...@confluent.io> wrote:
>> >>
>> >> > This is a reminder that the deadline for the vote is this Monday, Jan
>> >> 26,
>> >> > 7pm PT.
>> >> >
>> >> > Thanks,
>> >> >
>> >> > Jun
>> >> >
>> >> > On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io> wrote:
>> >> >
>> >> >> This is the second candidate for release of Apache Kafka 0.8.2.0.
>> There
>> >> >> has been some changes since the 0.8.2 beta release, especially in
>> the
>> >> new
>> >> >> java producer api and jmx mbean names. It would be great if people
>> can
>> >> test
>> >> >> this out thoroughly.
>> >> >>
>> >> >> Release Notes for the 0.8.2.0 release
>> >> >>
>> >> >>
>> >>
>> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
>> >> >>
>> >> >> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
>> >> >>
>> >> >> Kafka's KEYS file containing PGP keys we use to sign the release:
>> >> >> http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
>> >> >> (SHA256) checksum.
>> >> >>
>> >> >> * Release artifacts to be voted upon (source and binary):
>> >> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
>> >> >>
>> >> >> * Maven artifacts to be voted upon prior to release:
>> >> >> https://repository.apache.org/content/groups/staging/
>> >> >>
>> >> >> * scala-doc
>> >> >>
>> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
>> >> >>
>> >> >> * java-doc
>> >> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
>> >> >>
>> >> >> * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
>> >> >>
>> >> >>
>> >>
>> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
>> >> >> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
>> >> >>
>> >> >> /*******************************************
>> >> >>
>> >> >> Thanks,
>> >> >>
>> >> >> Jun
>> >> >>
>> >> >>
>> >> > --
>> >> > You received this message because you are subscribed to the Google
>> >> Groups
>> >> > "kafka-clients" group.
>> >> > To unsubscribe from this group and stop receiving emails from it,
>> send
>> >> an
>> >> > email to kafka-clients+unsubscribe@googlegroups.com.
>> >> > To post to this group, send email to kafka-clients@googlegroups.com.
>> >> > Visit this group at http://groups.google.com/group/kafka-clients.
>> >> > To view this discussion on the web visit
>> >> >
>> >>
>> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com
>> >> > <
>> >>
>> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com?utm_medium=email&utm_source=footer
>> >> >
>> >> > .
>> >> >
>> >> > For more options, visit https://groups.google.com/d/optout.
>> >> >
>> >>
>> >
>> > --
>> > You received this message because you are subscribed to the Google
>> Groups
>> > "kafka-clients" group.
>> > To unsubscribe from this group and stop receiving emails from it, send
>> an
>> > email to kafka-clients+unsubscribe@googlegroups.com.
>> > To post to this group, send email to kafka-clients@googlegroups.com.
>> > Visit this group at http://groups.google.com/group/kafka-clients.
>> > To view this discussion on the web visit
>> >
>> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com
>> > <
>> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com?utm_medium=email&utm_source=footer
>> >
>> > .
>> >
>> > For more options, visit https://groups.google.com/d/optout.
>> >
>>
>
> --
> You received this message because you are subscribed to the Google Groups
> "kafka-clients" group.
> To unsubscribe from this group and stop receiving emails from it, send an
> email to kafka-clients+unsubscribe@googlegroups.com.
> To post to this group, send email to kafka-clients@googlegroups.com.
> Visit this group at http://groups.google.com/group/kafka-clients.
> To view this discussion on the web visit
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJgO6mvJ-y8pe6ik5GuDp%2BvufoJi-U23LqVnbjXWj16JMw%40mail.gmail.com
> <https://groups.google.com/d/msgid/kafka-clients/CAOeJiJgO6mvJ-y8pe6ik5GuDp%2BvufoJi-U23LqVnbjXWj16JMw%40mail.gmail.com?utm_medium=email&utm_source=footer>
> .
>
> For more options, visit https://groups.google.com/d/optout.
>
Re: [kafka-clients] Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Joe Stein <jo...@stealth.ly>.
That makes sense, thanks!
On Sat, Jan 24, 2015 at 7:00 PM, Jay Kreps <ja...@gmail.com> wrote:
> But I think the flaw in trying to guess what kind of serializer they will
> use is when we get it wrong. Basically let's say we guess "String". Say 30%
> of the time we will be right and we will save the two configuration lines.
> 70% of the time we will be wrong and the user gets a super cryptic
> ClassCastException: "xyz cannot be cast to [B" (because [B is how java
> chooses to display the byte array class just to up the pain), then they
> figure out how to subscribe to our mailing list and email us the cryptic
> exception, then we explain about how we helpfully set these properties for
> them to save them time. :-)
>
> https://www.google.com/?gws_rd=ssl#q=kafka+classcastexception+%22%5BB%22
>
> I think basically we did this experiment with the old clients and the
> conclusion is that serialization is something you basically have to think
> about to use Kafka and trying to guess just makes things worse.
>
> -Jay
>
> On Sat, Jan 24, 2015 at 2:51 PM, Joe Stein <jo...@stealth.ly> wrote:
>
>> Maybe. I think the StringSerialzer could look more like a typical type of
>> message. Instead of encoding being a property it would be more typically
>> just written in the bytes.
>>
>> On Sat, Jan 24, 2015 at 12:12 AM, Jay Kreps <ja...@gmail.com> wrote:
>>
>> > I don't think so--see if you buy my explanation. We previously defaulted
>> > to the byte array serializer and it was a source of unending frustration
>> > and confusion. Since it wasn't a required config people just went along
>> > plugging in whatever objects they had, and thinking that changing the
>> > parametric types would somehow help. Then they would get a class case
>> > exception and assume our stuff was somehow busted, not realizing we had
>> > helpfully configured a type different from what they were passing in
>> under
>> > the covers. So I think it is actually good for people to think: how am I
>> > serializing my data, and getting that exception will make them ask that
>> > question right?
>> >
>> > -Jay
>> >
>> > On Fri, Jan 23, 2015 at 9:06 PM, Joe Stein <jo...@stealth.ly>
>> wrote:
>> >
>> >> Should value.serializer in the new java producer be defaulted to
>> >> Array[Byte] ?
>> >>
>> >> I was working on testing some upgrade paths and got this
>> >>
>> >> ! return exception in callback when buffer cannot accept message
>> >>
>> >> ConfigException: Missing required configuration
>> "value.serializer"
>> >> which has no default value. (ConfigDef.java:124)
>> >>
>> >> org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:124)
>> >>
>> >>
>> >>
>> >>
>> org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:48)
>> >>
>> >>
>> >>
>> >>
>> org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:235)
>> >>
>> >>
>> >>
>> >>
>> org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:129)
>> >>
>> >>
>> >>
>> >>
>> ly.stealth.testing.BaseSpec$class.createNewKafkaProducer(BaseSpec.scala:42)
>> >>
>> >>
>> ly.stealth.testing.KafkaSpec.createNewKafkaProducer(KafkaSpec.scala:36)
>> >>
>> >>
>> >>
>> >>
>> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:175)
>> >>
>> >>
>> >>
>> >>
>> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:170)
>> >>
>> >>
>> >>
>> >> On Fri, Jan 23, 2015 at 5:55 PM, Jun Rao <ju...@confluent.io> wrote:
>> >>
>> >> > This is a reminder that the deadline for the vote is this Monday, Jan
>> >> 26,
>> >> > 7pm PT.
>> >> >
>> >> > Thanks,
>> >> >
>> >> > Jun
>> >> >
>> >> > On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io> wrote:
>> >> >
>> >> >> This is the second candidate for release of Apache Kafka 0.8.2.0.
>> There
>> >> >> has been some changes since the 0.8.2 beta release, especially in
>> the
>> >> new
>> >> >> java producer api and jmx mbean names. It would be great if people
>> can
>> >> test
>> >> >> this out thoroughly.
>> >> >>
>> >> >> Release Notes for the 0.8.2.0 release
>> >> >>
>> >> >>
>> >>
>> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
>> >> >>
>> >> >> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
>> >> >>
>> >> >> Kafka's KEYS file containing PGP keys we use to sign the release:
>> >> >> http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
>> >> >> (SHA256) checksum.
>> >> >>
>> >> >> * Release artifacts to be voted upon (source and binary):
>> >> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
>> >> >>
>> >> >> * Maven artifacts to be voted upon prior to release:
>> >> >> https://repository.apache.org/content/groups/staging/
>> >> >>
>> >> >> * scala-doc
>> >> >>
>> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
>> >> >>
>> >> >> * java-doc
>> >> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
>> >> >>
>> >> >> * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
>> >> >>
>> >> >>
>> >>
>> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
>> >> >> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
>> >> >>
>> >> >> /*******************************************
>> >> >>
>> >> >> Thanks,
>> >> >>
>> >> >> Jun
>> >> >>
>> >> >>
>> >> > --
>> >> > You received this message because you are subscribed to the Google
>> >> Groups
>> >> > "kafka-clients" group.
>> >> > To unsubscribe from this group and stop receiving emails from it,
>> send
>> >> an
>> >> > email to kafka-clients+unsubscribe@googlegroups.com.
>> >> > To post to this group, send email to kafka-clients@googlegroups.com.
>> >> > Visit this group at http://groups.google.com/group/kafka-clients.
>> >> > To view this discussion on the web visit
>> >> >
>> >>
>> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com
>> >> > <
>> >>
>> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com?utm_medium=email&utm_source=footer
>> >> >
>> >> > .
>> >> >
>> >> > For more options, visit https://groups.google.com/d/optout.
>> >> >
>> >>
>> >
>> > --
>> > You received this message because you are subscribed to the Google
>> Groups
>> > "kafka-clients" group.
>> > To unsubscribe from this group and stop receiving emails from it, send
>> an
>> > email to kafka-clients+unsubscribe@googlegroups.com.
>> > To post to this group, send email to kafka-clients@googlegroups.com.
>> > Visit this group at http://groups.google.com/group/kafka-clients.
>> > To view this discussion on the web visit
>> >
>> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com
>> > <
>> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com?utm_medium=email&utm_source=footer
>> >
>> > .
>> >
>> > For more options, visit https://groups.google.com/d/optout.
>> >
>>
>
> --
> You received this message because you are subscribed to the Google Groups
> "kafka-clients" group.
> To unsubscribe from this group and stop receiving emails from it, send an
> email to kafka-clients+unsubscribe@googlegroups.com.
> To post to this group, send email to kafka-clients@googlegroups.com.
> Visit this group at http://groups.google.com/group/kafka-clients.
> To view this discussion on the web visit
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJgO6mvJ-y8pe6ik5GuDp%2BvufoJi-U23LqVnbjXWj16JMw%40mail.gmail.com
> <https://groups.google.com/d/msgid/kafka-clients/CAOeJiJgO6mvJ-y8pe6ik5GuDp%2BvufoJi-U23LqVnbjXWj16JMw%40mail.gmail.com?utm_medium=email&utm_source=footer>
> .
>
> For more options, visit https://groups.google.com/d/optout.
>
Re: [kafka-clients] Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Jay Kreps <ja...@gmail.com>.
But I think the flaw in trying to guess what kind of serializer they will
use is when we get it wrong. Basically let's say we guess "String". Say 30%
of the time we will be right and we will save the two configuration lines.
70% of the time we will be wrong and the user gets a super cryptic
ClassCastException: "xyz cannot be cast to [B" (because [B is how java
chooses to display the byte array class just to up the pain), then they
figure out how to subscribe to our mailing list and email us the cryptic
exception, then we explain about how we helpfully set these properties for
them to save them time. :-)
https://www.google.com/?gws_rd=ssl#q=kafka+classcastexception+%22%5BB%22
I think basically we did this experiment with the old clients and the
conclusion is that serialization is something you basically have to think
about to use Kafka and trying to guess just makes things worse.
-Jay
On Sat, Jan 24, 2015 at 2:51 PM, Joe Stein <jo...@stealth.ly> wrote:
> Maybe. I think the StringSerialzer could look more like a typical type of
> message. Instead of encoding being a property it would be more typically
> just written in the bytes.
>
> On Sat, Jan 24, 2015 at 12:12 AM, Jay Kreps <ja...@gmail.com> wrote:
>
> > I don't think so--see if you buy my explanation. We previously defaulted
> > to the byte array serializer and it was a source of unending frustration
> > and confusion. Since it wasn't a required config people just went along
> > plugging in whatever objects they had, and thinking that changing the
> > parametric types would somehow help. Then they would get a class case
> > exception and assume our stuff was somehow busted, not realizing we had
> > helpfully configured a type different from what they were passing in
> under
> > the covers. So I think it is actually good for people to think: how am I
> > serializing my data, and getting that exception will make them ask that
> > question right?
> >
> > -Jay
> >
> > On Fri, Jan 23, 2015 at 9:06 PM, Joe Stein <jo...@stealth.ly> wrote:
> >
> >> Should value.serializer in the new java producer be defaulted to
> >> Array[Byte] ?
> >>
> >> I was working on testing some upgrade paths and got this
> >>
> >> ! return exception in callback when buffer cannot accept message
> >>
> >> ConfigException: Missing required configuration "value.serializer"
> >> which has no default value. (ConfigDef.java:124)
> >>
> >> org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:124)
> >>
> >>
> >>
> >>
> org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:48)
> >>
> >>
> >>
> >>
> org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:235)
> >>
> >>
> >>
> >>
> org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:129)
> >>
> >>
> >>
> >>
> ly.stealth.testing.BaseSpec$class.createNewKafkaProducer(BaseSpec.scala:42)
> >>
> >>
> ly.stealth.testing.KafkaSpec.createNewKafkaProducer(KafkaSpec.scala:36)
> >>
> >>
> >>
> >>
> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:175)
> >>
> >>
> >>
> >>
> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:170)
> >>
> >>
> >>
> >> On Fri, Jan 23, 2015 at 5:55 PM, Jun Rao <ju...@confluent.io> wrote:
> >>
> >> > This is a reminder that the deadline for the vote is this Monday, Jan
> >> 26,
> >> > 7pm PT.
> >> >
> >> > Thanks,
> >> >
> >> > Jun
> >> >
> >> > On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io> wrote:
> >> >
> >> >> This is the second candidate for release of Apache Kafka 0.8.2.0.
> There
> >> >> has been some changes since the 0.8.2 beta release, especially in the
> >> new
> >> >> java producer api and jmx mbean names. It would be great if people
> can
> >> test
> >> >> this out thoroughly.
> >> >>
> >> >> Release Notes for the 0.8.2.0 release
> >> >>
> >> >>
> >>
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
> >> >>
> >> >> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
> >> >>
> >> >> Kafka's KEYS file containing PGP keys we use to sign the release:
> >> >> http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
> >> >> (SHA256) checksum.
> >> >>
> >> >> * Release artifacts to be voted upon (source and binary):
> >> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
> >> >>
> >> >> * Maven artifacts to be voted upon prior to release:
> >> >> https://repository.apache.org/content/groups/staging/
> >> >>
> >> >> * scala-doc
> >> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
> >> >>
> >> >> * java-doc
> >> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
> >> >>
> >> >> * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
> >> >>
> >> >>
> >>
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> >> >> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
> >> >>
> >> >> /*******************************************
> >> >>
> >> >> Thanks,
> >> >>
> >> >> Jun
> >> >>
> >> >>
> >> > --
> >> > You received this message because you are subscribed to the Google
> >> Groups
> >> > "kafka-clients" group.
> >> > To unsubscribe from this group and stop receiving emails from it, send
> >> an
> >> > email to kafka-clients+unsubscribe@googlegroups.com.
> >> > To post to this group, send email to kafka-clients@googlegroups.com.
> >> > Visit this group at http://groups.google.com/group/kafka-clients.
> >> > To view this discussion on the web visit
> >> >
> >>
> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com
> >> > <
> >>
> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com?utm_medium=email&utm_source=footer
> >> >
> >> > .
> >> >
> >> > For more options, visit https://groups.google.com/d/optout.
> >> >
> >>
> >
> > --
> > You received this message because you are subscribed to the Google Groups
> > "kafka-clients" group.
> > To unsubscribe from this group and stop receiving emails from it, send an
> > email to kafka-clients+unsubscribe@googlegroups.com.
> > To post to this group, send email to kafka-clients@googlegroups.com.
> > Visit this group at http://groups.google.com/group/kafka-clients.
> > To view this discussion on the web visit
> >
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com
> > <
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com?utm_medium=email&utm_source=footer
> >
> > .
> >
> > For more options, visit https://groups.google.com/d/optout.
> >
>
Re: [kafka-clients] Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Jay Kreps <ja...@gmail.com>.
But I think the flaw in trying to guess what kind of serializer they will
use is when we get it wrong. Basically let's say we guess "String". Say 30%
of the time we will be right and we will save the two configuration lines.
70% of the time we will be wrong and the user gets a super cryptic
ClassCastException: "xyz cannot be cast to [B" (because [B is how java
chooses to display the byte array class just to up the pain), then they
figure out how to subscribe to our mailing list and email us the cryptic
exception, then we explain about how we helpfully set these properties for
them to save them time. :-)
https://www.google.com/?gws_rd=ssl#q=kafka+classcastexception+%22%5BB%22
I think basically we did this experiment with the old clients and the
conclusion is that serialization is something you basically have to think
about to use Kafka and trying to guess just makes things worse.
-Jay
On Sat, Jan 24, 2015 at 2:51 PM, Joe Stein <jo...@stealth.ly> wrote:
> Maybe. I think the StringSerialzer could look more like a typical type of
> message. Instead of encoding being a property it would be more typically
> just written in the bytes.
>
> On Sat, Jan 24, 2015 at 12:12 AM, Jay Kreps <ja...@gmail.com> wrote:
>
> > I don't think so--see if you buy my explanation. We previously defaulted
> > to the byte array serializer and it was a source of unending frustration
> > and confusion. Since it wasn't a required config people just went along
> > plugging in whatever objects they had, and thinking that changing the
> > parametric types would somehow help. Then they would get a class case
> > exception and assume our stuff was somehow busted, not realizing we had
> > helpfully configured a type different from what they were passing in
> under
> > the covers. So I think it is actually good for people to think: how am I
> > serializing my data, and getting that exception will make them ask that
> > question right?
> >
> > -Jay
> >
> > On Fri, Jan 23, 2015 at 9:06 PM, Joe Stein <jo...@stealth.ly> wrote:
> >
> >> Should value.serializer in the new java producer be defaulted to
> >> Array[Byte] ?
> >>
> >> I was working on testing some upgrade paths and got this
> >>
> >> ! return exception in callback when buffer cannot accept message
> >>
> >> ConfigException: Missing required configuration "value.serializer"
> >> which has no default value. (ConfigDef.java:124)
> >>
> >> org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:124)
> >>
> >>
> >>
> >>
> org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:48)
> >>
> >>
> >>
> >>
> org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:235)
> >>
> >>
> >>
> >>
> org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:129)
> >>
> >>
> >>
> >>
> ly.stealth.testing.BaseSpec$class.createNewKafkaProducer(BaseSpec.scala:42)
> >>
> >>
> ly.stealth.testing.KafkaSpec.createNewKafkaProducer(KafkaSpec.scala:36)
> >>
> >>
> >>
> >>
> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:175)
> >>
> >>
> >>
> >>
> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:170)
> >>
> >>
> >>
> >> On Fri, Jan 23, 2015 at 5:55 PM, Jun Rao <ju...@confluent.io> wrote:
> >>
> >> > This is a reminder that the deadline for the vote is this Monday, Jan
> >> 26,
> >> > 7pm PT.
> >> >
> >> > Thanks,
> >> >
> >> > Jun
> >> >
> >> > On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io> wrote:
> >> >
> >> >> This is the second candidate for release of Apache Kafka 0.8.2.0.
> There
> >> >> has been some changes since the 0.8.2 beta release, especially in the
> >> new
> >> >> java producer api and jmx mbean names. It would be great if people
> can
> >> test
> >> >> this out thoroughly.
> >> >>
> >> >> Release Notes for the 0.8.2.0 release
> >> >>
> >> >>
> >>
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
> >> >>
> >> >> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
> >> >>
> >> >> Kafka's KEYS file containing PGP keys we use to sign the release:
> >> >> http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
> >> >> (SHA256) checksum.
> >> >>
> >> >> * Release artifacts to be voted upon (source and binary):
> >> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
> >> >>
> >> >> * Maven artifacts to be voted upon prior to release:
> >> >> https://repository.apache.org/content/groups/staging/
> >> >>
> >> >> * scala-doc
> >> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
> >> >>
> >> >> * java-doc
> >> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
> >> >>
> >> >> * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
> >> >>
> >> >>
> >>
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> >> >> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
> >> >>
> >> >> /*******************************************
> >> >>
> >> >> Thanks,
> >> >>
> >> >> Jun
> >> >>
> >> >>
> >> > --
> >> > You received this message because you are subscribed to the Google
> >> Groups
> >> > "kafka-clients" group.
> >> > To unsubscribe from this group and stop receiving emails from it, send
> >> an
> >> > email to kafka-clients+unsubscribe@googlegroups.com.
> >> > To post to this group, send email to kafka-clients@googlegroups.com.
> >> > Visit this group at http://groups.google.com/group/kafka-clients.
> >> > To view this discussion on the web visit
> >> >
> >>
> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com
> >> > <
> >>
> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com?utm_medium=email&utm_source=footer
> >> >
> >> > .
> >> >
> >> > For more options, visit https://groups.google.com/d/optout.
> >> >
> >>
> >
> > --
> > You received this message because you are subscribed to the Google Groups
> > "kafka-clients" group.
> > To unsubscribe from this group and stop receiving emails from it, send an
> > email to kafka-clients+unsubscribe@googlegroups.com.
> > To post to this group, send email to kafka-clients@googlegroups.com.
> > Visit this group at http://groups.google.com/group/kafka-clients.
> > To view this discussion on the web visit
> >
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com
> > <
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com?utm_medium=email&utm_source=footer
> >
> > .
> >
> > For more options, visit https://groups.google.com/d/optout.
> >
>
Re: [kafka-clients] Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Joe Stein <jo...@stealth.ly>.
Maybe. I think the StringSerialzer could look more like a typical type of
message. Instead of encoding being a property it would be more typically
just written in the bytes.
On Sat, Jan 24, 2015 at 12:12 AM, Jay Kreps <ja...@gmail.com> wrote:
> I don't think so--see if you buy my explanation. We previously defaulted
> to the byte array serializer and it was a source of unending frustration
> and confusion. Since it wasn't a required config people just went along
> plugging in whatever objects they had, and thinking that changing the
> parametric types would somehow help. Then they would get a class case
> exception and assume our stuff was somehow busted, not realizing we had
> helpfully configured a type different from what they were passing in under
> the covers. So I think it is actually good for people to think: how am I
> serializing my data, and getting that exception will make them ask that
> question right?
>
> -Jay
>
> On Fri, Jan 23, 2015 at 9:06 PM, Joe Stein <jo...@stealth.ly> wrote:
>
>> Should value.serializer in the new java producer be defaulted to
>> Array[Byte] ?
>>
>> I was working on testing some upgrade paths and got this
>>
>> ! return exception in callback when buffer cannot accept message
>>
>> ConfigException: Missing required configuration "value.serializer"
>> which has no default value. (ConfigDef.java:124)
>>
>> org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:124)
>>
>>
>>
>> org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:48)
>>
>>
>>
>> org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:235)
>>
>>
>>
>> org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:129)
>>
>>
>>
>> ly.stealth.testing.BaseSpec$class.createNewKafkaProducer(BaseSpec.scala:42)
>>
>> ly.stealth.testing.KafkaSpec.createNewKafkaProducer(KafkaSpec.scala:36)
>>
>>
>>
>> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:175)
>>
>>
>>
>> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:170)
>>
>>
>>
>> On Fri, Jan 23, 2015 at 5:55 PM, Jun Rao <ju...@confluent.io> wrote:
>>
>> > This is a reminder that the deadline for the vote is this Monday, Jan
>> 26,
>> > 7pm PT.
>> >
>> > Thanks,
>> >
>> > Jun
>> >
>> > On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io> wrote:
>> >
>> >> This is the second candidate for release of Apache Kafka 0.8.2.0. There
>> >> has been some changes since the 0.8.2 beta release, especially in the
>> new
>> >> java producer api and jmx mbean names. It would be great if people can
>> test
>> >> this out thoroughly.
>> >>
>> >> Release Notes for the 0.8.2.0 release
>> >>
>> >>
>> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
>> >>
>> >> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
>> >>
>> >> Kafka's KEYS file containing PGP keys we use to sign the release:
>> >> http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
>> >> (SHA256) checksum.
>> >>
>> >> * Release artifacts to be voted upon (source and binary):
>> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
>> >>
>> >> * Maven artifacts to be voted upon prior to release:
>> >> https://repository.apache.org/content/groups/staging/
>> >>
>> >> * scala-doc
>> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
>> >>
>> >> * java-doc
>> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
>> >>
>> >> * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
>> >>
>> >>
>> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
>> >> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
>> >>
>> >> /*******************************************
>> >>
>> >> Thanks,
>> >>
>> >> Jun
>> >>
>> >>
>> > --
>> > You received this message because you are subscribed to the Google
>> Groups
>> > "kafka-clients" group.
>> > To unsubscribe from this group and stop receiving emails from it, send
>> an
>> > email to kafka-clients+unsubscribe@googlegroups.com.
>> > To post to this group, send email to kafka-clients@googlegroups.com.
>> > Visit this group at http://groups.google.com/group/kafka-clients.
>> > To view this discussion on the web visit
>> >
>> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com
>> > <
>> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com?utm_medium=email&utm_source=footer
>> >
>> > .
>> >
>> > For more options, visit https://groups.google.com/d/optout.
>> >
>>
>
> --
> You received this message because you are subscribed to the Google Groups
> "kafka-clients" group.
> To unsubscribe from this group and stop receiving emails from it, send an
> email to kafka-clients+unsubscribe@googlegroups.com.
> To post to this group, send email to kafka-clients@googlegroups.com.
> Visit this group at http://groups.google.com/group/kafka-clients.
> To view this discussion on the web visit
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com
> <https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com?utm_medium=email&utm_source=footer>
> .
>
> For more options, visit https://groups.google.com/d/optout.
>
Re: [kafka-clients] Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Joe Stein <jo...@stealth.ly>.
Maybe. I think the StringSerialzer could look more like a typical type of
message. Instead of encoding being a property it would be more typically
just written in the bytes.
On Sat, Jan 24, 2015 at 12:12 AM, Jay Kreps <ja...@gmail.com> wrote:
> I don't think so--see if you buy my explanation. We previously defaulted
> to the byte array serializer and it was a source of unending frustration
> and confusion. Since it wasn't a required config people just went along
> plugging in whatever objects they had, and thinking that changing the
> parametric types would somehow help. Then they would get a class case
> exception and assume our stuff was somehow busted, not realizing we had
> helpfully configured a type different from what they were passing in under
> the covers. So I think it is actually good for people to think: how am I
> serializing my data, and getting that exception will make them ask that
> question right?
>
> -Jay
>
> On Fri, Jan 23, 2015 at 9:06 PM, Joe Stein <jo...@stealth.ly> wrote:
>
>> Should value.serializer in the new java producer be defaulted to
>> Array[Byte] ?
>>
>> I was working on testing some upgrade paths and got this
>>
>> ! return exception in callback when buffer cannot accept message
>>
>> ConfigException: Missing required configuration "value.serializer"
>> which has no default value. (ConfigDef.java:124)
>>
>> org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:124)
>>
>>
>>
>> org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:48)
>>
>>
>>
>> org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:235)
>>
>>
>>
>> org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:129)
>>
>>
>>
>> ly.stealth.testing.BaseSpec$class.createNewKafkaProducer(BaseSpec.scala:42)
>>
>> ly.stealth.testing.KafkaSpec.createNewKafkaProducer(KafkaSpec.scala:36)
>>
>>
>>
>> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:175)
>>
>>
>>
>> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:170)
>>
>>
>>
>> On Fri, Jan 23, 2015 at 5:55 PM, Jun Rao <ju...@confluent.io> wrote:
>>
>> > This is a reminder that the deadline for the vote is this Monday, Jan
>> 26,
>> > 7pm PT.
>> >
>> > Thanks,
>> >
>> > Jun
>> >
>> > On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io> wrote:
>> >
>> >> This is the second candidate for release of Apache Kafka 0.8.2.0. There
>> >> has been some changes since the 0.8.2 beta release, especially in the
>> new
>> >> java producer api and jmx mbean names. It would be great if people can
>> test
>> >> this out thoroughly.
>> >>
>> >> Release Notes for the 0.8.2.0 release
>> >>
>> >>
>> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
>> >>
>> >> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
>> >>
>> >> Kafka's KEYS file containing PGP keys we use to sign the release:
>> >> http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
>> >> (SHA256) checksum.
>> >>
>> >> * Release artifacts to be voted upon (source and binary):
>> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
>> >>
>> >> * Maven artifacts to be voted upon prior to release:
>> >> https://repository.apache.org/content/groups/staging/
>> >>
>> >> * scala-doc
>> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
>> >>
>> >> * java-doc
>> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
>> >>
>> >> * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
>> >>
>> >>
>> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
>> >> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
>> >>
>> >> /*******************************************
>> >>
>> >> Thanks,
>> >>
>> >> Jun
>> >>
>> >>
>> > --
>> > You received this message because you are subscribed to the Google
>> Groups
>> > "kafka-clients" group.
>> > To unsubscribe from this group and stop receiving emails from it, send
>> an
>> > email to kafka-clients+unsubscribe@googlegroups.com.
>> > To post to this group, send email to kafka-clients@googlegroups.com.
>> > Visit this group at http://groups.google.com/group/kafka-clients.
>> > To view this discussion on the web visit
>> >
>> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com
>> > <
>> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com?utm_medium=email&utm_source=footer
>> >
>> > .
>> >
>> > For more options, visit https://groups.google.com/d/optout.
>> >
>>
>
> --
> You received this message because you are subscribed to the Google Groups
> "kafka-clients" group.
> To unsubscribe from this group and stop receiving emails from it, send an
> email to kafka-clients+unsubscribe@googlegroups.com.
> To post to this group, send email to kafka-clients@googlegroups.com.
> Visit this group at http://groups.google.com/group/kafka-clients.
> To view this discussion on the web visit
> https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com
> <https://groups.google.com/d/msgid/kafka-clients/CAOeJiJhB_ncKnk48Jw3TbpbULzq6oZRZSKDBOXdid%2BV_WzHuhQ%40mail.gmail.com?utm_medium=email&utm_source=footer>
> .
>
> For more options, visit https://groups.google.com/d/optout.
>
Re: [kafka-clients] Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Jay Kreps <ja...@gmail.com>.
I don't think so--see if you buy my explanation. We previously defaulted to
the byte array serializer and it was a source of unending frustration and
confusion. Since it wasn't a required config people just went along
plugging in whatever objects they had, and thinking that changing the
parametric types would somehow help. Then they would get a class case
exception and assume our stuff was somehow busted, not realizing we had
helpfully configured a type different from what they were passing in under
the covers. So I think it is actually good for people to think: how am I
serializing my data, and getting that exception will make them ask that
question right?
-Jay
On Fri, Jan 23, 2015 at 9:06 PM, Joe Stein <jo...@stealth.ly> wrote:
> Should value.serializer in the new java producer be defaulted to
> Array[Byte] ?
>
> I was working on testing some upgrade paths and got this
>
> ! return exception in callback when buffer cannot accept message
>
> ConfigException: Missing required configuration "value.serializer"
> which has no default value. (ConfigDef.java:124)
>
> org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:124)
>
>
>
> org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:48)
>
>
>
> org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:235)
>
>
>
> org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:129)
>
>
> ly.stealth.testing.BaseSpec$class.createNewKafkaProducer(BaseSpec.scala:42)
>
> ly.stealth.testing.KafkaSpec.createNewKafkaProducer(KafkaSpec.scala:36)
>
>
>
> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:175)
>
>
>
> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:170)
>
>
>
> On Fri, Jan 23, 2015 at 5:55 PM, Jun Rao <ju...@confluent.io> wrote:
>
> > This is a reminder that the deadline for the vote is this Monday, Jan 26,
> > 7pm PT.
> >
> > Thanks,
> >
> > Jun
> >
> > On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io> wrote:
> >
> >> This is the second candidate for release of Apache Kafka 0.8.2.0. There
> >> has been some changes since the 0.8.2 beta release, especially in the
> new
> >> java producer api and jmx mbean names. It would be great if people can
> test
> >> this out thoroughly.
> >>
> >> Release Notes for the 0.8.2.0 release
> >>
> >>
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
> >>
> >> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
> >>
> >> Kafka's KEYS file containing PGP keys we use to sign the release:
> >> http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
> >> (SHA256) checksum.
> >>
> >> * Release artifacts to be voted upon (source and binary):
> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
> >>
> >> * Maven artifacts to be voted upon prior to release:
> >> https://repository.apache.org/content/groups/staging/
> >>
> >> * scala-doc
> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
> >>
> >> * java-doc
> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
> >>
> >> * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
> >>
> >>
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> >> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
> >>
> >> /*******************************************
> >>
> >> Thanks,
> >>
> >> Jun
> >>
> >>
> > --
> > You received this message because you are subscribed to the Google Groups
> > "kafka-clients" group.
> > To unsubscribe from this group and stop receiving emails from it, send an
> > email to kafka-clients+unsubscribe@googlegroups.com.
> > To post to this group, send email to kafka-clients@googlegroups.com.
> > Visit this group at http://groups.google.com/group/kafka-clients.
> > To view this discussion on the web visit
> >
> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com
> > <
> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com?utm_medium=email&utm_source=footer
> >
> > .
> >
> > For more options, visit https://groups.google.com/d/optout.
> >
>
Re: [kafka-clients] Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Jay Kreps <ja...@gmail.com>.
I don't think so--see if you buy my explanation. We previously defaulted to
the byte array serializer and it was a source of unending frustration and
confusion. Since it wasn't a required config people just went along
plugging in whatever objects they had, and thinking that changing the
parametric types would somehow help. Then they would get a class case
exception and assume our stuff was somehow busted, not realizing we had
helpfully configured a type different from what they were passing in under
the covers. So I think it is actually good for people to think: how am I
serializing my data, and getting that exception will make them ask that
question right?
-Jay
On Fri, Jan 23, 2015 at 9:06 PM, Joe Stein <jo...@stealth.ly> wrote:
> Should value.serializer in the new java producer be defaulted to
> Array[Byte] ?
>
> I was working on testing some upgrade paths and got this
>
> ! return exception in callback when buffer cannot accept message
>
> ConfigException: Missing required configuration "value.serializer"
> which has no default value. (ConfigDef.java:124)
>
> org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:124)
>
>
>
> org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:48)
>
>
>
> org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:235)
>
>
>
> org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:129)
>
>
> ly.stealth.testing.BaseSpec$class.createNewKafkaProducer(BaseSpec.scala:42)
>
> ly.stealth.testing.KafkaSpec.createNewKafkaProducer(KafkaSpec.scala:36)
>
>
>
> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:175)
>
>
>
> ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:170)
>
>
>
> On Fri, Jan 23, 2015 at 5:55 PM, Jun Rao <ju...@confluent.io> wrote:
>
> > This is a reminder that the deadline for the vote is this Monday, Jan 26,
> > 7pm PT.
> >
> > Thanks,
> >
> > Jun
> >
> > On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io> wrote:
> >
> >> This is the second candidate for release of Apache Kafka 0.8.2.0. There
> >> has been some changes since the 0.8.2 beta release, especially in the
> new
> >> java producer api and jmx mbean names. It would be great if people can
> test
> >> this out thoroughly.
> >>
> >> Release Notes for the 0.8.2.0 release
> >>
> >>
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
> >>
> >> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
> >>
> >> Kafka's KEYS file containing PGP keys we use to sign the release:
> >> http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
> >> (SHA256) checksum.
> >>
> >> * Release artifacts to be voted upon (source and binary):
> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
> >>
> >> * Maven artifacts to be voted upon prior to release:
> >> https://repository.apache.org/content/groups/staging/
> >>
> >> * scala-doc
> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
> >>
> >> * java-doc
> >> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
> >>
> >> * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
> >>
> >>
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> >> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
> >>
> >> /*******************************************
> >>
> >> Thanks,
> >>
> >> Jun
> >>
> >>
> > --
> > You received this message because you are subscribed to the Google Groups
> > "kafka-clients" group.
> > To unsubscribe from this group and stop receiving emails from it, send an
> > email to kafka-clients+unsubscribe@googlegroups.com.
> > To post to this group, send email to kafka-clients@googlegroups.com.
> > Visit this group at http://groups.google.com/group/kafka-clients.
> > To view this discussion on the web visit
> >
> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com
> > <
> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com?utm_medium=email&utm_source=footer
> >
> > .
> >
> > For more options, visit https://groups.google.com/d/optout.
> >
>
Re: [kafka-clients] Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Joe Stein <jo...@stealth.ly>.
Should value.serializer in the new java producer be defaulted to
Array[Byte] ?
I was working on testing some upgrade paths and got this
! return exception in callback when buffer cannot accept message
ConfigException: Missing required configuration "value.serializer"
which has no default value. (ConfigDef.java:124)
org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:124)
org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:48)
org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:235)
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:129)
ly.stealth.testing.BaseSpec$class.createNewKafkaProducer(BaseSpec.scala:42)
ly.stealth.testing.KafkaSpec.createNewKafkaProducer(KafkaSpec.scala:36)
ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:175)
ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:170)
On Fri, Jan 23, 2015 at 5:55 PM, Jun Rao <ju...@confluent.io> wrote:
> This is a reminder that the deadline for the vote is this Monday, Jan 26,
> 7pm PT.
>
> Thanks,
>
> Jun
>
> On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io> wrote:
>
>> This is the second candidate for release of Apache Kafka 0.8.2.0. There
>> has been some changes since the 0.8.2 beta release, especially in the new
>> java producer api and jmx mbean names. It would be great if people can test
>> this out thoroughly.
>>
>> Release Notes for the 0.8.2.0 release
>>
>> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
>>
>> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
>>
>> Kafka's KEYS file containing PGP keys we use to sign the release:
>> http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
>> (SHA256) checksum.
>>
>> * Release artifacts to be voted upon (source and binary):
>> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
>>
>> * Maven artifacts to be voted upon prior to release:
>> https://repository.apache.org/content/groups/staging/
>>
>> * scala-doc
>> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
>>
>> * java-doc
>> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
>>
>> * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
>>
>> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
>> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
>>
>> /*******************************************
>>
>> Thanks,
>>
>> Jun
>>
>>
> --
> You received this message because you are subscribed to the Google Groups
> "kafka-clients" group.
> To unsubscribe from this group and stop receiving emails from it, send an
> email to kafka-clients+unsubscribe@googlegroups.com.
> To post to this group, send email to kafka-clients@googlegroups.com.
> Visit this group at http://groups.google.com/group/kafka-clients.
> To view this discussion on the web visit
> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com
> <https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com?utm_medium=email&utm_source=footer>
> .
>
> For more options, visit https://groups.google.com/d/optout.
>
Re: [kafka-clients] Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Joe Stein <jo...@stealth.ly>.
Should value.serializer in the new java producer be defaulted to
Array[Byte] ?
I was working on testing some upgrade paths and got this
! return exception in callback when buffer cannot accept message
ConfigException: Missing required configuration "value.serializer"
which has no default value. (ConfigDef.java:124)
org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:124)
org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:48)
org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:235)
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:129)
ly.stealth.testing.BaseSpec$class.createNewKafkaProducer(BaseSpec.scala:42)
ly.stealth.testing.KafkaSpec.createNewKafkaProducer(KafkaSpec.scala:36)
ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:175)
ly.stealth.testing.KafkaSpec$$anonfun$3$$anonfun$apply$37.apply(KafkaSpec.scala:170)
On Fri, Jan 23, 2015 at 5:55 PM, Jun Rao <ju...@confluent.io> wrote:
> This is a reminder that the deadline for the vote is this Monday, Jan 26,
> 7pm PT.
>
> Thanks,
>
> Jun
>
> On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io> wrote:
>
>> This is the second candidate for release of Apache Kafka 0.8.2.0. There
>> has been some changes since the 0.8.2 beta release, especially in the new
>> java producer api and jmx mbean names. It would be great if people can test
>> this out thoroughly.
>>
>> Release Notes for the 0.8.2.0 release
>>
>> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
>>
>> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
>>
>> Kafka's KEYS file containing PGP keys we use to sign the release:
>> http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
>> (SHA256) checksum.
>>
>> * Release artifacts to be voted upon (source and binary):
>> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
>>
>> * Maven artifacts to be voted upon prior to release:
>> https://repository.apache.org/content/groups/staging/
>>
>> * scala-doc
>> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
>>
>> * java-doc
>> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
>>
>> * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
>>
>> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
>> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
>>
>> /*******************************************
>>
>> Thanks,
>>
>> Jun
>>
>>
> --
> You received this message because you are subscribed to the Google Groups
> "kafka-clients" group.
> To unsubscribe from this group and stop receiving emails from it, send an
> email to kafka-clients+unsubscribe@googlegroups.com.
> To post to this group, send email to kafka-clients@googlegroups.com.
> Visit this group at http://groups.google.com/group/kafka-clients.
> To view this discussion on the web visit
> https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com
> <https://groups.google.com/d/msgid/kafka-clients/CAFc58G83a%3DsvoKkkB3476kpbcQ8p0Fob6vtJYj9CgxMACvvEEQ%40mail.gmail.com?utm_medium=email&utm_source=footer>
> .
>
> For more options, visit https://groups.google.com/d/optout.
>
Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Jun Rao <ju...@confluent.io>.
This is a reminder that the deadline for the vote is this Monday, Jan 26,
7pm PT.
Thanks,
Jun
On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io> wrote:
> This is the second candidate for release of Apache Kafka 0.8.2.0. There
> has been some changes since the 0.8.2 beta release, especially in the new
> java producer api and jmx mbean names. It would be great if people can test
> this out thoroughly.
>
> Release Notes for the 0.8.2.0 release
>
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
>
> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
>
> Kafka's KEYS file containing PGP keys we use to sign the release:
> http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
> (SHA256) checksum.
>
> * Release artifacts to be voted upon (source and binary):
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
>
> * Maven artifacts to be voted upon prior to release:
> https://repository.apache.org/content/groups/staging/
>
> * scala-doc
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
>
> * java-doc
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
>
> * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
>
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
>
> /*******************************************
>
> Thanks,
>
> Jun
>
>
Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Jun Rao <ju...@confluent.io>.
That's right. What's in maven staging is always for the latest RC being
voted. The stuff in maven staging will be promoted to maven central once
the vote passes.
Thanks,
Jun
On Wed, Jan 21, 2015 at 10:35 AM, Jason Rosenberg <jb...@squareup.com> wrote:
> For the maven artifacts listed above, there doesn't seem to be any
> distinction between rc1 or rc2, so is it assumed that this is release2
> here?:
>
>
> https://repository.apache.org/content/groups/staging/org/apache/kafka/kafka_2.11/0.8.2.0/
>
> Thanks!
>
> Jason
>
> On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io> wrote:
>
> > This is the second candidate for release of Apache Kafka 0.8.2.0. There
> has
> > been some changes since the 0.8.2 beta release, especially in the new
> java
> > producer api and jmx mbean names. It would be great if people can test
> this
> > out thoroughly.
> >
> > Release Notes for the 0.8.2.0 release
> >
> >
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
> >
> > *** Please download, test and vote by Monday, Jan 26h, 7pm PT
> >
> > Kafka's KEYS file containing PGP keys we use to sign the release:
> > http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
> > (SHA256)
> > checksum.
> >
> > * Release artifacts to be voted upon (source and binary):
> > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
> >
> > * Maven artifacts to be voted upon prior to release:
> > https://repository.apache.org/content/groups/staging/
> >
> > * scala-doc
> > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
> >
> > * java-doc
> > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
> >
> > * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
> >
> >
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> > (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
> >
> > /*******************************************
> >
> > Thanks,
> >
> > Jun
> >
>
Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Jun Rao <ju...@confluent.io>.
That's right. What's in maven staging is always for the latest RC being
voted. The stuff in maven staging will be promoted to maven central once
the vote passes.
Thanks,
Jun
On Wed, Jan 21, 2015 at 10:35 AM, Jason Rosenberg <jb...@squareup.com> wrote:
> For the maven artifacts listed above, there doesn't seem to be any
> distinction between rc1 or rc2, so is it assumed that this is release2
> here?:
>
>
> https://repository.apache.org/content/groups/staging/org/apache/kafka/kafka_2.11/0.8.2.0/
>
> Thanks!
>
> Jason
>
> On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io> wrote:
>
> > This is the second candidate for release of Apache Kafka 0.8.2.0. There
> has
> > been some changes since the 0.8.2 beta release, especially in the new
> java
> > producer api and jmx mbean names. It would be great if people can test
> this
> > out thoroughly.
> >
> > Release Notes for the 0.8.2.0 release
> >
> >
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
> >
> > *** Please download, test and vote by Monday, Jan 26h, 7pm PT
> >
> > Kafka's KEYS file containing PGP keys we use to sign the release:
> > http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
> > (SHA256)
> > checksum.
> >
> > * Release artifacts to be voted upon (source and binary):
> > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
> >
> > * Maven artifacts to be voted upon prior to release:
> > https://repository.apache.org/content/groups/staging/
> >
> > * scala-doc
> > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
> >
> > * java-doc
> > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
> >
> > * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
> >
> >
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> > (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
> >
> > /*******************************************
> >
> > Thanks,
> >
> > Jun
> >
>
Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Jason Rosenberg <jb...@squareup.com>.
For the maven artifacts listed above, there doesn't seem to be any
distinction between rc1 or rc2, so is it assumed that this is release2
here?:
https://repository.apache.org/content/groups/staging/org/apache/kafka/kafka_2.11/0.8.2.0/
Thanks!
Jason
On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io> wrote:
> This is the second candidate for release of Apache Kafka 0.8.2.0. There has
> been some changes since the 0.8.2 beta release, especially in the new java
> producer api and jmx mbean names. It would be great if people can test this
> out thoroughly.
>
> Release Notes for the 0.8.2.0 release
>
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
>
> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
>
> Kafka's KEYS file containing PGP keys we use to sign the release:
> http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
> (SHA256)
> checksum.
>
> * Release artifacts to be voted upon (source and binary):
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
>
> * Maven artifacts to be voted upon prior to release:
> https://repository.apache.org/content/groups/staging/
>
> * scala-doc
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
>
> * java-doc
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
>
> * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
>
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
>
> /*******************************************
>
> Thanks,
>
> Jun
>
Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Jun Rao <ju...@confluent.io>.
Kyle,
Also, which reporter are you using for Graphite?
Thanks,
Jun
On Mon, Jan 26, 2015 at 4:08 PM, Kyle Banker <ky...@gmail.com> wrote:
> This is still preliminary, but it looks as if the change to metric names
> for per-topic metrics (bytes/messages in/out) is preventing these metrics
> from being reported to Yammer/Graphite. If this isn't intentional, it
> should probably be addressed before release.
>
> On Wed, Jan 21, 2015 at 9:28 AM, Jun Rao <ju...@confluent.io> wrote:
>
> > This is the second candidate for release of Apache Kafka 0.8.2.0. There
> has
> > been some changes since the 0.8.2 beta release, especially in the new
> java
> > producer api and jmx mbean names. It would be great if people can test
> this
> > out thoroughly.
> >
> > Release Notes for the 0.8.2.0 release
> >
> >
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
> >
> > *** Please download, test and vote by Monday, Jan 26h, 7pm PT
> >
> > Kafka's KEYS file containing PGP keys we use to sign the release:
> > http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
> > (SHA256)
> > checksum.
> >
> > * Release artifacts to be voted upon (source and binary):
> > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
> >
> > * Maven artifacts to be voted upon prior to release:
> > https://repository.apache.org/content/groups/staging/
> >
> > * scala-doc
> > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
> >
> > * java-doc
> > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
> >
> > * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
> >
> >
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> > (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
> >
> > /*******************************************
> >
> > Thanks,
> >
> > Jun
> >
>
Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Jun Rao <ju...@confluent.io>.
Hi, Everyone,
We identified a blocker issue related to Yammer jmx reporter (
https://issues.apache.org/jira/browse/KAFKA-1902). We are addressing this
issue right now. Once it's resolved, we will roll out a new RC for voting.
Thanks,
Jun
On Mon, Jan 26, 2015 at 5:14 PM, Otis Gospodnetic <
otis.gospodnetic@gmail.com> wrote:
> Hi,
>
> Don't use Graphite, so I don't know. Kyle, maybe you can share more info?
> What do you mean by "reported to Yammer" for example? And when you say
> Yammer/Graphite, are you trying to say that you are using the Graphite
> Reporter? If so, can you try other Yammer Reporters and see if there is a
> more general issue or something limited to either Graphite or Graphite
> Reporter?
>
> I am pretty sure we are able to see all Kafka 0.8.2 metrics nicely in SPM
> (in non-public version of the Kafka monitoring agent).
>
> Otis
> --
> Monitoring * Alerting * Anomaly Detection * Centralized Log Management
> Solr & Elasticsearch Support * http://sematext.com/
>
>
> On Mon, Jan 26, 2015 at 7:37 PM, Jun Rao <ju...@confluent.io> wrote:
>
> > Hmm, that's not the intention. The per-topic mbeans are definitely
> > registered by Yammer. So, not sure why it's not reported to Graphite.
> >
> > Otis, Vladimir,
> >
> > Do you guys know?
> >
> > Thanks,
> >
> > Jun
> >
> >
> >
> > On Mon, Jan 26, 2015 at 4:08 PM, Kyle Banker <ky...@gmail.com>
> wrote:
> >
> > > This is still preliminary, but it looks as if the change to metric
> names
> > > for per-topic metrics (bytes/messages in/out) is preventing these
> metrics
> > > from being reported to Yammer/Graphite. If this isn't intentional, it
> > > should probably be addressed before release.
> > >
> > > On Wed, Jan 21, 2015 at 9:28 AM, Jun Rao <ju...@confluent.io> wrote:
> > >
> > > > This is the second candidate for release of Apache Kafka 0.8.2.0.
> There
> > > has
> > > > been some changes since the 0.8.2 beta release, especially in the new
> > > java
> > > > producer api and jmx mbean names. It would be great if people can
> test
> > > this
> > > > out thoroughly.
> > > >
> > > > Release Notes for the 0.8.2.0 release
> > > >
> > > >
> > >
> >
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
> > > >
> > > > *** Please download, test and vote by Monday, Jan 26h, 7pm PT
> > > >
> > > > Kafka's KEYS file containing PGP keys we use to sign the release:
> > > > http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
> > > > (SHA256)
> > > > checksum.
> > > >
> > > > * Release artifacts to be voted upon (source and binary):
> > > > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
> > > >
> > > > * Maven artifacts to be voted upon prior to release:
> > > > https://repository.apache.org/content/groups/staging/
> > > >
> > > > * scala-doc
> > > > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
> > > >
> > > > * java-doc
> > > > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
> > > >
> > > > * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
> > > >
> > > >
> > >
> >
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> > > > (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
> > > >
> > > > /*******************************************
> > > >
> > > > Thanks,
> > > >
> > > > Jun
> > > >
> > >
> >
>
Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Jun Rao <ju...@confluent.io>.
Hi, Everyone,
We identified a blocker issue related to Yammer jmx reporter (
https://issues.apache.org/jira/browse/KAFKA-1902). We are addressing this
issue right now. Once it's resolved, we will roll out a new RC for voting.
Thanks,
Jun
On Mon, Jan 26, 2015 at 5:14 PM, Otis Gospodnetic <
otis.gospodnetic@gmail.com> wrote:
> Hi,
>
> Don't use Graphite, so I don't know. Kyle, maybe you can share more info?
> What do you mean by "reported to Yammer" for example? And when you say
> Yammer/Graphite, are you trying to say that you are using the Graphite
> Reporter? If so, can you try other Yammer Reporters and see if there is a
> more general issue or something limited to either Graphite or Graphite
> Reporter?
>
> I am pretty sure we are able to see all Kafka 0.8.2 metrics nicely in SPM
> (in non-public version of the Kafka monitoring agent).
>
> Otis
> --
> Monitoring * Alerting * Anomaly Detection * Centralized Log Management
> Solr & Elasticsearch Support * http://sematext.com/
>
>
> On Mon, Jan 26, 2015 at 7:37 PM, Jun Rao <ju...@confluent.io> wrote:
>
> > Hmm, that's not the intention. The per-topic mbeans are definitely
> > registered by Yammer. So, not sure why it's not reported to Graphite.
> >
> > Otis, Vladimir,
> >
> > Do you guys know?
> >
> > Thanks,
> >
> > Jun
> >
> >
> >
> > On Mon, Jan 26, 2015 at 4:08 PM, Kyle Banker <ky...@gmail.com>
> wrote:
> >
> > > This is still preliminary, but it looks as if the change to metric
> names
> > > for per-topic metrics (bytes/messages in/out) is preventing these
> metrics
> > > from being reported to Yammer/Graphite. If this isn't intentional, it
> > > should probably be addressed before release.
> > >
> > > On Wed, Jan 21, 2015 at 9:28 AM, Jun Rao <ju...@confluent.io> wrote:
> > >
> > > > This is the second candidate for release of Apache Kafka 0.8.2.0.
> There
> > > has
> > > > been some changes since the 0.8.2 beta release, especially in the new
> > > java
> > > > producer api and jmx mbean names. It would be great if people can
> test
> > > this
> > > > out thoroughly.
> > > >
> > > > Release Notes for the 0.8.2.0 release
> > > >
> > > >
> > >
> >
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
> > > >
> > > > *** Please download, test and vote by Monday, Jan 26h, 7pm PT
> > > >
> > > > Kafka's KEYS file containing PGP keys we use to sign the release:
> > > > http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
> > > > (SHA256)
> > > > checksum.
> > > >
> > > > * Release artifacts to be voted upon (source and binary):
> > > > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
> > > >
> > > > * Maven artifacts to be voted upon prior to release:
> > > > https://repository.apache.org/content/groups/staging/
> > > >
> > > > * scala-doc
> > > > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
> > > >
> > > > * java-doc
> > > > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
> > > >
> > > > * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
> > > >
> > > >
> > >
> >
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> > > > (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
> > > >
> > > > /*******************************************
> > > >
> > > > Thanks,
> > > >
> > > > Jun
> > > >
> > >
> >
>
Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Otis Gospodnetic <ot...@gmail.com>.
Hi,
Don't use Graphite, so I don't know. Kyle, maybe you can share more info?
What do you mean by "reported to Yammer" for example? And when you say
Yammer/Graphite, are you trying to say that you are using the Graphite
Reporter? If so, can you try other Yammer Reporters and see if there is a
more general issue or something limited to either Graphite or Graphite
Reporter?
I am pretty sure we are able to see all Kafka 0.8.2 metrics nicely in SPM
(in non-public version of the Kafka monitoring agent).
Otis
--
Monitoring * Alerting * Anomaly Detection * Centralized Log Management
Solr & Elasticsearch Support * http://sematext.com/
On Mon, Jan 26, 2015 at 7:37 PM, Jun Rao <ju...@confluent.io> wrote:
> Hmm, that's not the intention. The per-topic mbeans are definitely
> registered by Yammer. So, not sure why it's not reported to Graphite.
>
> Otis, Vladimir,
>
> Do you guys know?
>
> Thanks,
>
> Jun
>
>
>
> On Mon, Jan 26, 2015 at 4:08 PM, Kyle Banker <ky...@gmail.com> wrote:
>
> > This is still preliminary, but it looks as if the change to metric names
> > for per-topic metrics (bytes/messages in/out) is preventing these metrics
> > from being reported to Yammer/Graphite. If this isn't intentional, it
> > should probably be addressed before release.
> >
> > On Wed, Jan 21, 2015 at 9:28 AM, Jun Rao <ju...@confluent.io> wrote:
> >
> > > This is the second candidate for release of Apache Kafka 0.8.2.0. There
> > has
> > > been some changes since the 0.8.2 beta release, especially in the new
> > java
> > > producer api and jmx mbean names. It would be great if people can test
> > this
> > > out thoroughly.
> > >
> > > Release Notes for the 0.8.2.0 release
> > >
> > >
> >
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
> > >
> > > *** Please download, test and vote by Monday, Jan 26h, 7pm PT
> > >
> > > Kafka's KEYS file containing PGP keys we use to sign the release:
> > > http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
> > > (SHA256)
> > > checksum.
> > >
> > > * Release artifacts to be voted upon (source and binary):
> > > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
> > >
> > > * Maven artifacts to be voted upon prior to release:
> > > https://repository.apache.org/content/groups/staging/
> > >
> > > * scala-doc
> > > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
> > >
> > > * java-doc
> > > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
> > >
> > > * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
> > >
> > >
> >
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> > > (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
> > >
> > > /*******************************************
> > >
> > > Thanks,
> > >
> > > Jun
> > >
> >
>
Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Otis Gospodnetic <ot...@gmail.com>.
Hi,
Don't use Graphite, so I don't know. Kyle, maybe you can share more info?
What do you mean by "reported to Yammer" for example? And when you say
Yammer/Graphite, are you trying to say that you are using the Graphite
Reporter? If so, can you try other Yammer Reporters and see if there is a
more general issue or something limited to either Graphite or Graphite
Reporter?
I am pretty sure we are able to see all Kafka 0.8.2 metrics nicely in SPM
(in non-public version of the Kafka monitoring agent).
Otis
--
Monitoring * Alerting * Anomaly Detection * Centralized Log Management
Solr & Elasticsearch Support * http://sematext.com/
On Mon, Jan 26, 2015 at 7:37 PM, Jun Rao <ju...@confluent.io> wrote:
> Hmm, that's not the intention. The per-topic mbeans are definitely
> registered by Yammer. So, not sure why it's not reported to Graphite.
>
> Otis, Vladimir,
>
> Do you guys know?
>
> Thanks,
>
> Jun
>
>
>
> On Mon, Jan 26, 2015 at 4:08 PM, Kyle Banker <ky...@gmail.com> wrote:
>
> > This is still preliminary, but it looks as if the change to metric names
> > for per-topic metrics (bytes/messages in/out) is preventing these metrics
> > from being reported to Yammer/Graphite. If this isn't intentional, it
> > should probably be addressed before release.
> >
> > On Wed, Jan 21, 2015 at 9:28 AM, Jun Rao <ju...@confluent.io> wrote:
> >
> > > This is the second candidate for release of Apache Kafka 0.8.2.0. There
> > has
> > > been some changes since the 0.8.2 beta release, especially in the new
> > java
> > > producer api and jmx mbean names. It would be great if people can test
> > this
> > > out thoroughly.
> > >
> > > Release Notes for the 0.8.2.0 release
> > >
> > >
> >
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
> > >
> > > *** Please download, test and vote by Monday, Jan 26h, 7pm PT
> > >
> > > Kafka's KEYS file containing PGP keys we use to sign the release:
> > > http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
> > > (SHA256)
> > > checksum.
> > >
> > > * Release artifacts to be voted upon (source and binary):
> > > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
> > >
> > > * Maven artifacts to be voted upon prior to release:
> > > https://repository.apache.org/content/groups/staging/
> > >
> > > * scala-doc
> > > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
> > >
> > > * java-doc
> > > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
> > >
> > > * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
> > >
> > >
> >
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> > > (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
> > >
> > > /*******************************************
> > >
> > > Thanks,
> > >
> > > Jun
> > >
> >
>
Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Jun Rao <ju...@confluent.io>.
Hmm, that's not the intention. The per-topic mbeans are definitely
registered by Yammer. So, not sure why it's not reported to Graphite.
Otis, Vladimir,
Do you guys know?
Thanks,
Jun
On Mon, Jan 26, 2015 at 4:08 PM, Kyle Banker <ky...@gmail.com> wrote:
> This is still preliminary, but it looks as if the change to metric names
> for per-topic metrics (bytes/messages in/out) is preventing these metrics
> from being reported to Yammer/Graphite. If this isn't intentional, it
> should probably be addressed before release.
>
> On Wed, Jan 21, 2015 at 9:28 AM, Jun Rao <ju...@confluent.io> wrote:
>
> > This is the second candidate for release of Apache Kafka 0.8.2.0. There
> has
> > been some changes since the 0.8.2 beta release, especially in the new
> java
> > producer api and jmx mbean names. It would be great if people can test
> this
> > out thoroughly.
> >
> > Release Notes for the 0.8.2.0 release
> >
> >
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
> >
> > *** Please download, test and vote by Monday, Jan 26h, 7pm PT
> >
> > Kafka's KEYS file containing PGP keys we use to sign the release:
> > http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
> > (SHA256)
> > checksum.
> >
> > * Release artifacts to be voted upon (source and binary):
> > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
> >
> > * Maven artifacts to be voted upon prior to release:
> > https://repository.apache.org/content/groups/staging/
> >
> > * scala-doc
> > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
> >
> > * java-doc
> > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
> >
> > * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
> >
> >
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> > (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
> >
> > /*******************************************
> >
> > Thanks,
> >
> > Jun
> >
>
Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Jun Rao <ju...@confluent.io>.
Hmm, that's not the intention. The per-topic mbeans are definitely
registered by Yammer. So, not sure why it's not reported to Graphite.
Otis, Vladimir,
Do you guys know?
Thanks,
Jun
On Mon, Jan 26, 2015 at 4:08 PM, Kyle Banker <ky...@gmail.com> wrote:
> This is still preliminary, but it looks as if the change to metric names
> for per-topic metrics (bytes/messages in/out) is preventing these metrics
> from being reported to Yammer/Graphite. If this isn't intentional, it
> should probably be addressed before release.
>
> On Wed, Jan 21, 2015 at 9:28 AM, Jun Rao <ju...@confluent.io> wrote:
>
> > This is the second candidate for release of Apache Kafka 0.8.2.0. There
> has
> > been some changes since the 0.8.2 beta release, especially in the new
> java
> > producer api and jmx mbean names. It would be great if people can test
> this
> > out thoroughly.
> >
> > Release Notes for the 0.8.2.0 release
> >
> >
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
> >
> > *** Please download, test and vote by Monday, Jan 26h, 7pm PT
> >
> > Kafka's KEYS file containing PGP keys we use to sign the release:
> > http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
> > (SHA256)
> > checksum.
> >
> > * Release artifacts to be voted upon (source and binary):
> > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
> >
> > * Maven artifacts to be voted upon prior to release:
> > https://repository.apache.org/content/groups/staging/
> >
> > * scala-doc
> > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
> >
> > * java-doc
> > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
> >
> > * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
> >
> >
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> > (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
> >
> > /*******************************************
> >
> > Thanks,
> >
> > Jun
> >
>
Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Jun Rao <ju...@confluent.io>.
Kyle,
Also, which reporter are you using for Graphite?
Thanks,
Jun
On Mon, Jan 26, 2015 at 4:08 PM, Kyle Banker <ky...@gmail.com> wrote:
> This is still preliminary, but it looks as if the change to metric names
> for per-topic metrics (bytes/messages in/out) is preventing these metrics
> from being reported to Yammer/Graphite. If this isn't intentional, it
> should probably be addressed before release.
>
> On Wed, Jan 21, 2015 at 9:28 AM, Jun Rao <ju...@confluent.io> wrote:
>
> > This is the second candidate for release of Apache Kafka 0.8.2.0. There
> has
> > been some changes since the 0.8.2 beta release, especially in the new
> java
> > producer api and jmx mbean names. It would be great if people can test
> this
> > out thoroughly.
> >
> > Release Notes for the 0.8.2.0 release
> >
> >
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
> >
> > *** Please download, test and vote by Monday, Jan 26h, 7pm PT
> >
> > Kafka's KEYS file containing PGP keys we use to sign the release:
> > http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
> > (SHA256)
> > checksum.
> >
> > * Release artifacts to be voted upon (source and binary):
> > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
> >
> > * Maven artifacts to be voted upon prior to release:
> > https://repository.apache.org/content/groups/staging/
> >
> > * scala-doc
> > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
> >
> > * java-doc
> > https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
> >
> > * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
> >
> >
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> > (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
> >
> > /*******************************************
> >
> > Thanks,
> >
> > Jun
> >
>
Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Kyle Banker <ky...@gmail.com>.
This is still preliminary, but it looks as if the change to metric names
for per-topic metrics (bytes/messages in/out) is preventing these metrics
from being reported to Yammer/Graphite. If this isn't intentional, it
should probably be addressed before release.
On Wed, Jan 21, 2015 at 9:28 AM, Jun Rao <ju...@confluent.io> wrote:
> This is the second candidate for release of Apache Kafka 0.8.2.0. There has
> been some changes since the 0.8.2 beta release, especially in the new java
> producer api and jmx mbean names. It would be great if people can test this
> out thoroughly.
>
> Release Notes for the 0.8.2.0 release
>
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
>
> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
>
> Kafka's KEYS file containing PGP keys we use to sign the release:
> http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
> (SHA256)
> checksum.
>
> * Release artifacts to be voted upon (source and binary):
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
>
> * Maven artifacts to be voted upon prior to release:
> https://repository.apache.org/content/groups/staging/
>
> * scala-doc
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
>
> * java-doc
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
>
> * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
>
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
>
> /*******************************************
>
> Thanks,
>
> Jun
>
Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Kyle Banker <ky...@gmail.com>.
This is still preliminary, but it looks as if the change to metric names
for per-topic metrics (bytes/messages in/out) is preventing these metrics
from being reported to Yammer/Graphite. If this isn't intentional, it
should probably be addressed before release.
On Wed, Jan 21, 2015 at 9:28 AM, Jun Rao <ju...@confluent.io> wrote:
> This is the second candidate for release of Apache Kafka 0.8.2.0. There has
> been some changes since the 0.8.2 beta release, especially in the new java
> producer api and jmx mbean names. It would be great if people can test this
> out thoroughly.
>
> Release Notes for the 0.8.2.0 release
>
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
>
> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
>
> Kafka's KEYS file containing PGP keys we use to sign the release:
> http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
> (SHA256)
> checksum.
>
> * Release artifacts to be voted upon (source and binary):
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
>
> * Maven artifacts to be voted upon prior to release:
> https://repository.apache.org/content/groups/staging/
>
> * scala-doc
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
>
> * java-doc
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
>
> * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
>
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
>
> /*******************************************
>
> Thanks,
>
> Jun
>
Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Jun Rao <ju...@confluent.io>.
This is a reminder that the deadline for the vote is this Monday, Jan 26,
7pm PT.
Thanks,
Jun
On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io> wrote:
> This is the second candidate for release of Apache Kafka 0.8.2.0. There
> has been some changes since the 0.8.2 beta release, especially in the new
> java producer api and jmx mbean names. It would be great if people can test
> this out thoroughly.
>
> Release Notes for the 0.8.2.0 release
>
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
>
> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
>
> Kafka's KEYS file containing PGP keys we use to sign the release:
> http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
> (SHA256) checksum.
>
> * Release artifacts to be voted upon (source and binary):
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
>
> * Maven artifacts to be voted upon prior to release:
> https://repository.apache.org/content/groups/staging/
>
> * scala-doc
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
>
> * java-doc
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
>
> * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
>
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
>
> /*******************************************
>
> Thanks,
>
> Jun
>
>
Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Jason Rosenberg <jb...@squareup.com>.
For the maven artifacts listed above, there doesn't seem to be any
distinction between rc1 or rc2, so is it assumed that this is release2
here?:
https://repository.apache.org/content/groups/staging/org/apache/kafka/kafka_2.11/0.8.2.0/
Thanks!
Jason
On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io> wrote:
> This is the second candidate for release of Apache Kafka 0.8.2.0. There has
> been some changes since the 0.8.2 beta release, especially in the new java
> producer api and jmx mbean names. It would be great if people can test this
> out thoroughly.
>
> Release Notes for the 0.8.2.0 release
>
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
>
> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
>
> Kafka's KEYS file containing PGP keys we use to sign the release:
> http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
> (SHA256)
> checksum.
>
> * Release artifacts to be voted upon (source and binary):
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
>
> * Maven artifacts to be voted upon prior to release:
> https://repository.apache.org/content/groups/staging/
>
> * scala-doc
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
>
> * java-doc
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
>
> * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
>
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
>
> /*******************************************
>
> Thanks,
>
> Jun
>
Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)
Posted by Jun Rao <ju...@confluent.io>.
+1 (binding) Verified quick start and unit tests.
Thanks,
Jun
On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao <ju...@confluent.io> wrote:
> This is the second candidate for release of Apache Kafka 0.8.2.0. There
> has been some changes since the 0.8.2 beta release, especially in the new
> java producer api and jmx mbean names. It would be great if people can test
> this out thoroughly.
>
> Release Notes for the 0.8.2.0 release
>
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/RELEASE_NOTES.html
>
> *** Please download, test and vote by Monday, Jan 26h, 7pm PT
>
> Kafka's KEYS file containing PGP keys we use to sign the release:
> http://kafka.apache.org/KEYS in addition to the md5, sha1 and sha2
> (SHA256) checksum.
>
> * Release artifacts to be voted upon (source and binary):
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
>
> * Maven artifacts to be voted upon prior to release:
> https://repository.apache.org/content/groups/staging/
>
> * scala-doc
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/scaladoc/
>
> * java-doc
> https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/javadoc/
>
> * The tag to be voted upon (off the 0.8.2 branch) is the 0.8.2.0 tag
>
> https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h=058d58adef2ab2787e49d8efeefd61bb3d32f99c
> (commit 0b312a6b9f0833d38eec434bfff4c647c1814564)
>
> /*******************************************
>
> Thanks,
>
> Jun
>
>