[
https://issues.apache.org/jira/browse/SAMZA-633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14393047#comment-14393047
]
Dan Harvey commented on SAMZA-633:
----------------------------------
For more context I'm trying to use the Avro encoder/decode from the [confluent
schema-registry|https://github.com/confluentinc/schema-registry/blob/master/avro-serializer/src/main/java/io/confluent/kafka/serializers/KafkaAvroDecoder.java]
which don't have a default constructor and need configuration passing in to be
useful.
I've attached a patch which I think adds this.
> 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
>
> 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)
