手动提交偏移量可以更精确地控制提交的时机,而自动提交偏移量可以减少应用代码的复杂性。根据应用的需求,可以选择合适的提交方式。 消费者组协调器(Consumer Group Coordinator):Kafka提供了消费者组协调器来管理消费者组的协调工作。协调器负责分配分区给消费者组中的消费者,并跟踪每个消费者的偏移量。通过协调器,Kafka可以确保每个分区只被消费者组中的一个消费者消费,避免重复消费和消息丢失。
源库不支持阿里云RDS的只读副本。如果源数据库为自建库,并且安装了Percona Server for MySQL 5.6.x或Percona Server for MySQL 5.7.x时,内存管理器必须使用Jemalloc库,以避免因系统表频繁查询带来的内存回收不及时,并最终导致数据库Out of Memory问题。迁移过程中,不允许在源库创建库名为ib_logfile的数据库。