它是一个ConcurrentMap，key是TopicPartition类，代表一个topic的一个partition。value是一个包含ProducerBatch的双端队列。等待Sender线程发送给broker。画张图来看下：

Kafka 作为大数据技术生态的重要组件，尤其是实时流数据处理场景下，作为分布式生产/消费系统，得到广泛的重用。而 Kafka 在数据生产和消费上，日志是主要的场景。今天的大数据开发学习分享，我们就来讲讲 kafka 日志结构的基...

ProducerBatch#completeFutureAndFireCallbacks

Used for periodic real timetasks, eg. Videoencoding/decoding

线上有一个非常繁忙的服务的 JVM 进程 CPU 经常跑到 100% 以上，下面写了一下排查的过程。通过阅读这篇文章你会了解到下面这些知识。

近年来，随着深度学习在CV领域的广泛应用，人脸识别领域也得到了巨大的发展。在深度学习中，通过多层网络的连接，能够学习到图像的特征表示，那么两张人脸的图像，是不是可以通过深度学习判别其是否是相同的人呢？Google在2015年提...

程序或系统中关于异步的概念使用的比较多，那么什么是异步呢？下面举个生活中最常见的情景来进行说明：

随着互联网技术的发展，每一个业务都与数据息息相关，如搜索，推荐。这些业务有一个共同的特点是连接用户和数据。随着数据量的不断增加，对大数据的处理的要求也就会越来越高，在这期间出现了很多大数据的处理平台和工具，如Hado...

在学习Layer Normalization之前建议大家先自行学习Batch Normalization.

整个章节由浅入深了解Spring Batch，让你掌握批处理利器。面对大批量数据毫无惧色。本章只做介绍，后面章节有代码示例。好了，接下来是我们的主角Spring Batch。...