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 <hezekiahmai...@gmail.com> 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? >
