You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by Jay Kreps <ja...@gmail.com> on 2012/10/03 01:50:13 UTC

Producer code

Hey Guys,

The code in the Producer has gotten very dense and spaghetti-like. I see a
lot of types like
  Map[TopicAndPartition, Seq[ProducerData[K,Message]]]
or
  Option[Map[Int, Map[TopicAndPartition, Seq[ProducerData[K,Message]]]]]

Please, if you find this happening just make a new class that describes the
type.

-Jay

Re: Producer code

Posted by Jun Rao <ju...@gmail.com>.

I think you mean DefaultEventHandler. Yes, kafka-409 has been created for
that.

Thanks,

Jun

On Tue, Oct 2, 2012 at 4:50 PM, Jay Kreps <ja...@gmail.com> wrote:

> Hey Guys,
>
> The code in the Producer has gotten very dense and spaghetti-like. I see a
> lot of types like
>   Map[TopicAndPartition, Seq[ProducerData[K,Message]]]
> or
>   Option[Map[Int, Map[TopicAndPartition, Seq[ProducerData[K,Message]]]]]
>
> Please, if you find this happening just make a new class that describes the
> type.
>
> -Jay
>