[
https://issues.apache.org/jira/browse/SAMZA-633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14394217#comment-14394217
]
Dan Harvey commented on SAMZA-633:
----------------------------------
Thanks for getting that in quickly!
> 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
> Assignee: Dan Harvey
> Priority: Minor
> Fix For: 0.10.0
>
> 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)
