Hello:
  请教2个问题。
   1、flink 使用sql-client.sh -f xx.sql 怎么传递参数修改sql里面的文件。比如MySQL,Kafka的连接地址。
   2、flink sql消费Kafka 
设置group-offset,group.id之前没提交过,会直接报错。怎么设置成没提交过从earliest消费等等。
             感谢大家






回复