我想创建一个具有 KafkaSource 的 Flink 流应用程序。 KafkaSource 应该连接到与创建连接的任务管理器位于同一 AZ 中的代理。
我怎样才能做到这一点？关于实施的任何指示或之前有人尝试过吗？