flink读kafka写HBase的示例

可以回答这个问题，以下是一个示例：

Flink 读取 Kafka 数据并将其写入 HBase 的示例代码如下：

val env = StreamExecutionEnvironment.getExecutionEnvironment

val properties = new Properties()
properties.setProperty("bootstrap.servers", "localhost:9092")
properties.setProperty("group.id", "test")

val stream = env.addSource(new FlinkKafkaConsumer[String]("topic", new SimpleStringSchema(), properties))

val hbaseConf = HBaseConfiguration.create()
hbaseConf.set("hbase.zookeeper.quorum", "localhost")
hbaseConf.set("hbase.zookeeper.property.clientPort", "2181")

stream.addSink(new HBaseSink(hbaseConf, "table"))

env.execute("Flink Kafka HBase Example")

其中，`FlinkKafkaConsumer` 是 Flink 提供的 Kafka 消费者，`HBaseSink` 是自定义的 HBase Sink，用于将数据写入 HBase。在这个示例中，我们使用了简单的字符串序列化器 `SimpleStringSchema`，并将 Kafka 主题设置为 `topic`，将 HBase 表设置为 `table`。