Tobo

Is it possible to dynamically set output topic of StreamingDataFrame pipeline? I need the output topic name to be derived from message content. Something like this: `sdf.to_topic(lambda value: str(value["target_topic"]))` Native...