[jira] [Updated] (SAMZA-633) Pass configuration though to Kafka encoder/decoder in KafkaSerdeFactory

["Dan Harvey (JIRA)" <ji...@apache.org>]

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

Dan Harvey updated SAMZA-633:
-----------------------------
    Attachment: 0001-Pass-properties-through-to-the-Kafka-Encoder-and-Dec.patch

> Pass configuration though to Kafka encoder/decoder in KafkaSerdeFactory
> -----------------------------------------------------------------------
>
>                 Key: SAMZA-633
>                 URL: https://issues.apache.org/jira/browse/SAMZA-633
>             Project: Samza
>          Issue Type: Improvement
>          Components: kafka
>    Affects Versions: 0.9.0
>         Environment: Any
>            Reporter: Dan Harvey
>            Priority: Minor
>         Attachments: 0001-Pass-properties-through-to-the-Kafka-Encoder-and-Dec.patch
>
>
> The KafkaSerdeFactory currently constructs Kafka encoders and decoders using the default constructor with no parameters. Kafka generally constructs these by passing in a VerifiableProperties to allow the constructor to configure them.
> I think we can do this by taking properties out of Samza's configuration map as with the kafka encoder/decoder setting then passing these through to the constructors.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)