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 just via module definition file. I am not sure how
outbound topic name is being generated, however specifying that topic
name is important for us to create a test deployments in our
environments.
*****************************************************************************
---
kind: io.statefun.kafka.v1/egress
spec:
id: test/response
address: BOOTSTREAP_SERVERS
deliverySemantic:
type: at-least-once
transactionTimeoutMillis: 100000
*****************************************************************************
Thanks,
Deniz
[1]
https://nightlies.apache.org/flink/flink-statefun-docs-release-3.1/docs/io-module/apache-kafka/
