ZhangJian, Il giorno lun 8 nov 2021 alle ore 15:25 ZhangJian He <shoot...@gmail.com> ha scritto:
> ## background > Currently, as my business is an IoT platform which serves many companies. > We are trying to use pulsar functions to push messages to our customers' > kafka server. Here I face the problem, the KafkaSinkConfig can only receive > the `sslTruststoreLocation`. > And the Kafka Client now only support `sslTruststoreLocation`. > > ## solution > I want to add a config `sslTruststoreContent` in `KafkaIoConfig` which is a > base64 decoded string. > When the function starts, write the content to disk.(like > conf/$tenant/$namespace/$name/sslTruststore.jks) > When the function stops, delete the disk file. > +1 from my side Enrico > > > Thanks > ZhangJian He >
