请教下，使用Flink实现读取Kafka数据，对数据入数据库，并且按小时统计消息数量，也入数据库。

请教下，使用Flink实现读取Kafka数据，对数据入数据库，并且按小时统计消息数量，也入数据库。请问下java有例子可以提供吗？

最好去开源社区搜索一下，gitee和github