srcmini

2020-02-13半瓶木阅读(2469)评论(0)赞(1)

本文概述 消息压缩的需要 生产者批次/记录批次 消息压缩格式 消息压缩的缺点 如我们所见，生产者以文本格式（通常称为JSON格式）将数据发送到Kafka。 JSON有一个缺点，即数据以字符串形式存储。这将创建多个重复的记录以存储在Kafka...

2020-02-13半瓶木阅读(1320)评论(0)赞(1)

本文概述 时间 状态 流表对偶 时间窗 用户应了解以下有关流处理的概念： 时间 这是必不可少的，也是最令人困惑的概念。在流处理中，大多数操作都依赖时间。因此，对于这种流应用程序，通常的时间观念是典型的任务。 Kafka Stream处理涉及...

2020-02-13半瓶木阅读(1629)评论(0)赞(1)

本文概述 卡夫卡流 流处理 到目前为止，我们了解了主题，分区，将数据发送到Kafka以及从Kafka消费数据。这可能是较低的抽象级别。因此，需要更高级别的抽象。因此，这引入了Kafka流的概念。 卡夫卡流 通常，流定义了随时间提供的数据元素...

2020-02-13半瓶木阅读(1384)评论(0)赞(1)

到现在为止，我们学习了如何在Apache Kafka上读写数据。在本节中，我们将学习将真实数据源放入Kafka。 在这里，我们将讨论一个实时应用程序，即Twitter。用户将了解有关创建Twitter生产者以及如何产生Tweet的知识。 T...

2020-02-13半瓶木阅读(1390)评论(0)赞(1)

在本节中，我们将学习创建Twitter生产者。 创建Twitter生产者基本上需要三个步骤： 创建一个Twitter客户端。 创建生产者 发送推文 步骤1：按照包命名约定规则创建一个新的Java包。然后，在其中创建一个Java类，说“ tw...

2020-02-13半瓶木阅读(1272)评论(0)赞(0)

Apache Kafka是一个分布式系统，其中的主题在各个节点之间进行分区和复制。它还支持容错能力和耐用性。可能会有故障排除的机会。因此，需要管理和监视不同的Kafka活动。各种Kafka监视工具用于监视和显示纠正措施。 在Kafka监视下...

2020-02-13半瓶木阅读(1074)评论(0)赞(0)

Apache Kafka是一个分布式系统，其中的主题在各个节点之间进行分区和复制。它还支持容错能力和耐用性。可能会有故障排除的机会。因此，需要管理和监视不同的Kafka活动。各种Kafka监视工具用于监视和显示纠正措施。 在Kafka监视下...

2020-02-13半瓶木阅读(4897)评论(0)赞(0)

本文概述 创建记录器 创建消费者属性 创造消费者 订阅消费者 轮询新数据 读取消费者组中的数据 在上一节中，我们学习了用Java创建生产者。在本节中，我们将学习在Java中实现Kafka使用者。 要创建使用者，需要执行以下步骤： 创建记录器...

2020-02-13半瓶木阅读(5654)评论(0)赞(0)

本文概述 无Key生产者 带Key生产者 无Key生产者 在上一节中，我们了解了生产者如何将数据发送到Kafka。为了更深入地了解数据，即数据是否正确生成，在何处生成，有关其偏移量和分区值等。让我们了解更多信息。 为了执行回调，用户需要实现...

2020-02-13半瓶木阅读(2199)评论(0)赞(0)

本文概述 创建Java生产者 创建生产者属性 创建生产者记录 发送数据 在上一节中，我们学习了创建Kafka项目的基本步骤。现在，在用Java创建Kafka生产者之前，我们需要定义基本的Project依赖项。在我们的项目中，将需要两个依赖项...