Thanks, it works
On Wed, 26 Dec 2018 at 10:07 fudian.fd wrote:
> The exception is very clear that the SourceFunction should be
> serializable. Password is not serializable. You can try to set the kafka
> consumer properties such as this:
>
> props.put(SaslConfigs.SASL_JAAS_CONFIG, "LoginModule r
The exception is very clear that the SourceFunction should be serializable.
Password is not serializable. You can try to set the kafka consumer properties
such as this:
props.put(SaslConfigs.SASL_JAAS_CONFIG, "LoginModule required subject=\"test\"
secret=\"test\";");
The String value will be p
Hi team,
I am passing a security enabled kafka consumer properties to
FlinkKafkaConsumer but keep getting this
error java.io.NotSerializableException? what is the best way to handle this?
I use Flink 1.7.1 and here is the consumer property that produces the
exception
props.put(SaslConfigs.SASL_J
