如何处理所有Replica都不工作
上文提到，在ISR中至少有一个follower时，Kafka可以确保已经commit的数据不丢失，但如果某个Partition的所有Replica都宕机了，就无法保证数据不丢失了。这种情况下有两种可行的方案：
1.等待ISR中的任一个Replica“活”过来，并且选它作为Leader
2.选择第一个“活”过来的Replica（不一定是ISR中的）作为Leader
这就需要在可用性和一致性当中作出一个简单的折衷。如果一定要等待ISR中的Replica“活”过来，那不可用的时间就可能会相对较长。而且如果ISR中的所有Replica都无法“活”过来了，或者数据都丢失了，这个Partition将永远不可用。选择第一个“活”过来的Replica作为Leader，而这个Replica不是ISR中的Replica，那即使它并不保证已经包含了所有已commit的消息，它也会成为Leader而作为consumer的数据源（前文有说明，所有读写都由Leader完成）。Kafka0.8.*使用了第二种方式。根据Kafka的文档，在以后的版本中，Kafka支持用户通过配置选择这两种方式中的一种，从而根据不同的使用场景选择高可用性还是强一致性。 unclean.leader.election.enable 参数决定使用哪种方案，默认是true，采用第二种方案
参考：
- http://www.jasongj.com/2015/04/24/KafkaColumn2/
- http://www.jasongj.com/2015/06/08/KafkaColumn3/
- http://orchome.com/22
-
我正在使用spring批处理使用RepositoryItemReader从postgresql DB读取记录，然后将其写入主题。我看到大约有100万条记录需要处理，但它并没有处理所有的记录。我已经将reader的pageSize设置为10,000并且与提交间隔（块大小）相同
-
我有这个单声道代码: 当validate方法抛出ValidationException时，将同时调用handleValidation异常和handleException。我只希望调用handleValidationException。为什么会发生这种情况？如何防止handleException被调用？
-
问题内容： 如何运行选择所有非null的MySQL查询？就像 我只需要删除所有内容即可吗？ 问题答案： 您必须在每列上明确说明条件，例如
-
我的批处理作业不处理所有已读记录。 完成作业后，Spring批处理日志中读取了198282条记录，但在处理器中我有一条日志，在开始处理之前只记录了196503条，但有时，处理器处理了所有的记录。 步进 Spring启动版本:2.0.1
-
问题内容： 使用ant，maven和buildr有什么意义？在eclipse或netbeans中使用using构建会无法正常工作吗？我很好奇扩展构建工具的目的和好处是什么。 问题答案： 依赖管理 ：构建工具遵循组件模型，该组件模型提供有关在哪里寻找依赖的提示。在Eclipse / Netbeans中，您必须依赖JAR，并且您实际上并不知道此JAR是否已更新。使用这些构建工具，它们“知道”依赖项中的
-
问题内容： 我在Maven中设置Spring + Spring Data JPA + QueryDSL + JPA 2.0 + Hibernate的配置时遇到很多麻烦。我已经解决了很多问题，但这使我头痛= /。 我收到以下异常： 我在Google上进行了查看，大多数情况下，此问题是由缺少注释“ @Transactional”引起的。我试图注释我的方法，但没有解决任何问题。我完全不知道它来自=（）。