实时拿到数据后如何真正进行实时跑批？

肯定要用类似streaming或flink这样的流处理组件而不是跑批。具体可以两种实现方案，一是cdc的目标不要设置为数据库而是设置为kafka，然后对接kafka或者flink，这种比较容易；二是目标为数据库，然后自己写程序实现轮训，这种比较复杂但对大数据组件没要求，适合小数据量处理。