Hey all 👋 . We have existing java services that process Kafka events. We would like these events to trigger workflows in Flyte. Is this possible with flytekit-java or is there some other recommended way of doing this?

Flyte has endpoints to do this

Yea, looking through the code, there's a

FlyteAdminClient

that's part of the

jflyte-utils

, but I've not seen anything more official discussed

@alert-oil-1341 you can use the buf generated client itself

I would suggest generating stub from proto and calling flyteadmin gRPC endpoints. It's likely too much if you use flytekit-java because it is a full blown Flyte sdk.

Thanks for the response. I'll generate the stubs from

flyteidl-protos

dep.

I think go code is the best place to check for the oauth flow.

@steep-jackal-21573 can you help

@freezing-airport-6809 What do you refer to? The auth flow? Internally we don't use the standard flyteadmin auth flow directly, but with our own gateway in front to be able to use GCP auth flow. Between the gateway and flyteadmin, we use the static client_secret setup. The flytekit-java implementation unfortunately takes that assumption which is not very proper as part of open source, to be fair.

Cc @high-park-82026 why is implementing oauth2 annoying for every client

For me, I'm not apposed to implementing oAuth, but it's just non-differentiating work that will take up some time. I was hoping for a packaged up client w/ all the auth built in(refreshing token, etc.)

Isn’t this sad when you use a standard

I believe there should be standard oauth lib in Java.

I know @steep-jackal-21573 , this just reflection of how hard security makes the life of developers

Yeah, that I fully agree. 😄

Seems possible https://developer.okta.com/blog/2019/10/30/java-oauth2

I'll be doing this with a gRPC interceptor, but yea