FlinkKafkaConsumer problem

    hi,    i am confused about consumer group of FlinkKafkaConsumer,     i have two applications,with the same code like this: //--- val bsEnv = StreamExecutionEnvironment.getExecutionEnvironment Env.setRestartStrategy(RestartStrategies.noRestart()) val consumerProps =

How to use Hbase Connector Sink

hi  flink1.10??wen i want to sink data to hbase table like this??  bstEnv.sqlUpdate("""CREATE TABLE circle_weight (                            rowkey String,                            info ROW