-Re: kafka key serializer
Neha Narkhede 2013-04-12, 16:21
Correct, I should've been more specific. "key.serializer.class"
defaults to whatever "serializer.class" is set to.
On Fri, Apr 12, 2013 at 9:12 AM, Soby Chacko <[EMAIL PROTECTED]> wrote:
> Hi Neha,
> I could be understanding it wrong. I am looking at
> https://issues.apache.org/jira/browse/KAFKA-544 and see the following
> This patch does the following:
> 1. Change Encoder and Decoder to map between object and byte rather than
> between Message and object.
> 2. Require two encoders for the producer and two decoders for the consumer.
> This follows the same pattern as before: in the producer there is now
> serializer.class and key.serializer.class. *By default key.serializer takes
> the same value as serializer.class*. If no key is specified then this
> parameter is essentially ignored. In the consumer ConsumerConnector now
> requires two decoders, one for the key and one for the value.
> So, if this is true, then doesn't that mean key.serializer gets default to
> whatever value serializer.class takes, not the DefaultEncoder?
> Thanks again,
> Soby Chacko
> On Fri, Apr 12, 2013 at 11:38 AM, Neha Narkhede <[EMAIL PROTECTED]>wrote:
>> It defaults both key and value serializer to DefaultEncoder, but you
>> can customize both independently through "key.serializer.class" and
>> "serializer.class" config options.
>> On Fri, Apr 12, 2013 at 8:33 AM, Soby Chacko <[EMAIL PROTECTED]> wrote:
>> > Thanks for the reply. But, when I did some more research, it seems like
>> > using the same encoder for both. For example, if I provide
>> > explicitly, this serializer is used for both key and value. However, if I
>> > don't specify any serializer, then it appears that Kafka defaults to
>> > DefaultEncoder. Is that what you ment?
>> > Thanks again!!
>> > Soby Chacko
>> > On Wed, Apr 10, 2013 at 1:59 PM, Neha Narkhede <[EMAIL PROTECTED]
>> >> It will use DefaultEncoder.
>> >> Thanks,
>> >> Neha
>> >> On Wed, Apr 10, 2013 at 8:27 AM, Soby Chacko <[EMAIL PROTECTED]>
>> >> > If I don't provide an explicit key serializer but a serializer class
>> >> > value encoding), and then use a key in KeyedMessage, what will be the
>> >> > encoder used for key? Is it going to default to the same encoder used
>> >> > value or the DefaultEncoder?
>> >> >
>> >> > Thanks,
>> >> > Soby Chacko