GBase 8a
运维管理
文章

配置kafak consumer

小熊
发表于2026-08-18 17:54:38201次浏览1个评论

这里我自己模拟了简单的kafka服务 1、启动zk image.png 2、启动kafka image.png 3、kafka创建topic image.png 4、8a数据库创建对应的表 image.png 5、kafka生产数据 image.png 6、打开kafka消费者 image.png 7、配置8a的kafka consumer image.png 8、查看数据，并开启kafak consumer后再查看数据 image.png 9、kafka新增生产数据 image.png image.png 10、数据库再次查看数据 image.png 11、把数据清空，然后尝试用load导入数据 image.png image.png 12、把topic删除重建，且表删除重建，验证load导数正常 image.png image.png image.png image.png image.png 以上演示了通过kafak consumer和load两种方式从kafka中加载数据到gbase数据库中，若有其他疑问和不解可以在评论区讨论。

评论

登录后才可以发表评论
GBase用户51829发表于 1个月前
kafka‑consumer 是 GBase 内置常驻后台任务，适合生产实时 CDC 持续同步，自动维护 offset；load kafka:// 是一次性 SQL，多用于历史数据补数，需外部自行管理 offset。

热门帖子