卡夫卡和卡夫卡之间有什么不同?如果有的话,什么时候应该用一个而不是另一个,那会有什么好处?Kafka与Kafka Direct的区别?
3
A
回答
3
kafka direct是一种优化,它提供了更好的容错保证和更强的可靠性语义加班。
园1.2介绍Write Ahead Logs。它确保没有从任何可靠的数据源(即Flume,Kafka和Kinesis等事务源)接收的数据由于失败(即至少一次语义)而丢失。即使对于像普通旧套接字这样的不可靠(即非事务性)来源,它也可以最大限度地减少数据丢失。 参阅本link为更好地理解
0
新直接API卡夫卡 - 这允许发生故障时仍然只有一次处理的每个卡夫卡记录,不使用预写日志。这使得Spark Streaming + Kafka管道更高效,同时提供更强大的容错保证。
相关问题
- 1. Spark-Streaming Kafka Direct Streaming API&Parallelism
- 2. Kafka - DefaultPartitioner与MessageKey与自定义分区程序的区别?
- 3. Kafka 10 kafka-consumer-groups.sh与Kafka 8 kafka-run-class.sh ConsumerOffsetChecker
- 4. WSO2 MB与Apache Kafka
- 5. 与Kafka的Apache Mesos
- 6. KAFKA中的分区错误
- 7. Spark + Kafka streaming NoClassDefFoundError kafka/serializer/StringDecoder
- 8. angular.js与apache kafka的集成
- 9. Kafka Connect接收器分区:子分区?
- 10. Kafka OffsetOutOfRangeException
- 11. Apache Kafka:镜像与复制
- 12. 将Apache kafka与Angular.js集成
- 13. kafka与server.properties不采摘log4j
- 14. 向camel-kafka组件发送kafka确认
- 15. 将kafka(kafka-python)转储到txt文件
- 16. Kafka的分区选择算法
- 17. MQTT代理和Apache Kafka有什么区别
- 18. 如何分别处理Kafka分区并与Spark执行程序并行处理?
- 19. 在Apache Kafka中设置多个分区
- 20. Apache Kafka主题分区消息处理
- 21. Confluent Kafka:如何在confluent-kafka-python客户端中指定序列化和分区?
- 22. Bluemix Kafka streams
- 23. Kafka Connect集成
- 24. Kafka SASL off domain
- 25. KAFKA REMOTE AWS consumer.poll
- 26. Apache Kafka - Aggregation
- 27. Spark Streaming Kafka backpressure
- 28. Kafka和Zookeeper TLS
- 29. Logstash Kafka输出
- 30. ExecutorService关闭 - Kafka