这一篇主要来讲讲kafka的可靠性是如何实现的
1.kafka可靠性的基本机制
顺序性保证
Kafka可以保证分区消息的顺序。
如果使用同一个生产者往同一个分区写入消息,而且消息B在消息A之后写入,那么Kafka可以保证消息B的偏移量比消息A的偏移量大,而且消费者会先读取消息A再读取消息B。一致性保证
只有当消息被写入分区的所有同步副本时,它才被认为是 已提交。且消费者只能读取已提交的消息。可用性保证
只要还有一个副本是活跃的,那么已经提交的消息就不会丢失。
这一篇主要来讲讲kafka的可靠性是如何实现的
顺序性保证
Kafka可以保证分区消息的顺序。
如果使用同一个生产者往同一个分区写入消息,而且消息B在消息A之后写入,那么Kafka可以保证消息B的偏移量比消息A的偏移量大,而且消费者会先读取消息A再读取消息B。
一致性保证
只有当消息被写入分区的所有同步副本时,它才被认为是 已提交。且消费者只能读取已提交的消息。
可用性保证
只要还有一个副本是活跃的,那么已经提交的消息就不会丢失。