[
https://issues.apache.org/jira/browse/FLINK-16518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-16518:
----------------------------------------
Component/s: Stateful Functions
> Stateful Function's KafkaSinkProvider should use `setProperty` instead of
> `put` for resolving client properties
> ---------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-16518
> URL: https://issues.apache.org/jira/browse/FLINK-16518
> Project: Flink
> Issue Type: Bug
> Components: Stateful Functions
> Reporter: Tzu-Li (Gordon) Tai
> Assignee: Tzu-Li (Gordon) Tai
> Priority: Blocker
> Labels: pull-request-available
> Fix For: statefun-1.1
>
> Time Spent: 20m
> Remaining Estimate: 0h
>
> The {{put}} method is strongly discourage to be used on {{Properties}} as a
> bad practice, since it allows putting non-string values.
> This has already caused a bug, where a long was put into the properties,
> while Kafka was expecting an integer:
> {code}
> org.apache.kafka.common.config.ConfigException: Invalid value 100000 for
> configuration transaction.timeout.ms: Expected value to be a 32-bit integer,
> but it was a java.lang.Long
> at
> org.apache.kafka.common.config.ConfigDef.parseType(ConfigDef.java:669)
> at
> org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:471)
> at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:464)
> at
> org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:62)
> at
> org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:75)
> at
> org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:396)
> at
> org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:326)
> at
> org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:298)
> at
> org.apache.flink.streaming.connectors.kafka.internal.FlinkKafkaInternalProducer.<init>(FlinkKafkaInternalProducer.java:76)
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
