[ 
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784828#comment-16784828
 ] 

Guozhang Wang commented on KAFKA-3729:
--------------------------------------

[~mjsax] Yes `configure()` is tended to be idempotent, and if users impl is not 
to be idempotent they should use a boolean flag, e.g. to make sure the logic is 
executed only once.

[~yuzhih...@gmail.com] It is from the interface `ProcessorContext#appConfigs`, 
and yes they can be used. Note one tricky thing is that the configs are only 
passed in at the construction time of the KafkaStreams, whereas the topology is 
built beforehand, so we can only do the auto-configure at KafkaStreams 
construction time, not at the topology building time since users are passing in 
the serde objects.

>  Auto-configure non-default SerDes passed alongside the topology builder
> ------------------------------------------------------------------------
>
>                 Key: KAFKA-3729
>                 URL: https://issues.apache.org/jira/browse/KAFKA-3729
>             Project: Kafka
>          Issue Type: Improvement
>          Components: streams
>            Reporter: Fred Patton
>            Priority: Major
>              Labels: api, newbie
>
> From Guozhang Wang:
> "Only default serdes provided through configs are auto-configured today. But 
> we could auto-configure other serdes passed alongside the topology builder as 
> well."



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to