"Kafka in a“一文(at )的作者说:
Kafka为数据的一致性和可用性提供了以下保证:(1)发送到主题分区的消息将按照发送的顺序附加到提交日志中;(2)单个使用者实例将按照它们在日志中出现的顺序查看消息;(3)当所有同步副本都将其应用于其日志时,消息将被“提交”;(4)任何已提交的消息都不会丢失,只要同步副本中至少有一个是活着的。第一和第二保证确保为每个分区保留消息排序。请注
这个生产者将读取History表,以找到要选择的表和行,然后将该行添加到Kafka主题中。现在生产者需要确保将事件添加到Kafka主题中,其方式与History表登录的方式相同。因此,使用者读取它们的顺序与它在History表中记录的顺序相同,并在Postgrace上执行它。producer2 has message 6 to 10但是当我消费的时候,我会收到关于如下主题的消息</
我开发了一个Kafka version : 0.9.0.1应用程序,它不能丢失任何消息。这种方法可以很好地保证所有消息的传递,但是性能是完全不能接受的。但是,由于没有阻塞get(),我无法知道消息是否安全到达。
我知道我可以将一个Callback传递到发送中,并对我进行Kafka重试,但是这种方法有一个缺点,就是消息可能会被按顺序消耗。是否有可能异步发送卡夫卡<em