Hi, I am trying to consume a kafka topic using ReadFromKafka transform.
If i got it right, since ReadFromKafka is originally written in java, an expansion service is needed and default env is set to DOCKER, and in current implementation I can see that expansion service field is not adjustable (im not able to pass it as part of the transform's config). Is there currently a way to ReadFromKafka from a pipeline written with yaml api? If so, an explanation would be much appreciated. I saw there's some workaround suggested online of using Docker-in-Docker but would prefer to avoid it. Thanks Yarden
