Hi Deniz,
I assume that you are using the Python SDK,
Here is an example how to set the egress topic name[1]
I hope that helps,
Igal.
[1]
https://github.com/apache/flink-statefun-playground/blob/release-3.1/python/greeter/functions.py#L58
On Wed 19. Jan 2022 at 09:53, Deniz Koçak wrote:
> Hi,
Hi,
In an Kafka module definition [1], I want to explicitly set the name
of the outbound Kafka topic in the egress definition below, but could
not find any reference to it in the docs. We are not using Java SDK,
which seems to be allowing us to set such details, so not sure how it
could be handled
