请点击：微信原文

我们已经在之前的例子里看到,创建一个生产者对象必须指定序列化器。我们已经知道如何使用默认的字符串序列化器,Kafka还提供了整型和字节数组序列化器,不过它们还不足以满足大部分场景的需求。到最后,我们需要序列化的记录类型会越来越多。接下来演示如何开发自己的序列化器。如果发送到到Kafka的对象不是简单的字符串或整型,那么可以使用序列化框架来创建消息记[...]

概述考虑这样一种常用的情形：你需要将静态内容（类似图片、文件）展示给用户。那么这个情形就意味着你需要先将静态内容从磁盘中拷贝出来放到一个内存buf中，然后将这个buf通过socket传输给用户，进而用户或者静态内容的展示。这看起来再正常不过了，但是实际上这是很低效的流程，我们把上面的这种情形抽象成下面的过程：read(file, tmp_buf, [...]

近期打算翻译一下，2018年Kafka行业报告。敬请期待。Now in its third year, the survey of the Apache Kafka community shows how and why companies are adopting streaming platforms to build event-driven[...]

Kafka可以保证同一个分区里的消息是有序的。也就是说，如果生产者按照一定的顺序发送消息，broker就会按照这个顺序把它们写入分区，消费者也会按照同样的顺序读取它们。在某些情况下，顺序是非常重要的。例如，往一个账户存入100元再取出来，这个与先取钱再存钱是截然不同的！不过，有些场最对顺序不是很敏感。如果把retries设为非零整数，同时把max.[...]