Using Statefun with Confluent Kafka

[hezekiah maina]

I'm trying to use Statefun with the fully-managed Confluent Kafka as my
ingress and egress. Where should I define my credentials when using the
remote module?

[Tzu-Li (Gordon) Tai]

Hi,

Are the credentials usually supplied by setting them in the Kafka client
properties?
If so, you can set the client properties in remote modules as shown in [1].

Otherwise, could you briefly explain / point me to some link on the details
of how to authenticate for Confluent Kafka?

Best,
Gordon

[1]
https://github.com/apache/flink-statefun/blob/75b9dfec90c52d5cd41a97297ce1e768146fb745/statefun-flink/statefun-flink-io-bundle/src/test/resources/routable-protobuf-kafka-ingress.yaml#L36


On Thu, Oct 1, 2020, 6:42 PM hezekiah maina <[hidden email]>
wrote:

> I'm trying to use Statefun with the fully-managed Confluent Kafka as my
> ingress and egress. Where should I define my credentials when using the
> remote module?
>