Kafka溪流基本原理解释
-
null
共有1个答案
>
使用者API仍然以完全相同的方式在幕后工作。要回答这个问题--启动应用程序的更多运行实例；这些服务器不一定必须在完全不同的服务器上
不推荐使用Kafka流来执行不限于kafka-kafka交互的远程工作。至少不接受这会引入延迟，因此在进行依赖于时间窗口的主题连接时不应该这样做。Kafka Connect可以作为您的系统，将数据从主题传输到数据库
同样，Kafka Streams只是生产者/消费者API之上的一层。您仍然会得到相同的网络异常，或者，如果您读取了损坏的记录，则有处理毒丸记录的选项
-
我正在使用Kafka Streams，我注意到它使我的kafka日志记录了很多日志消息，例如： 这真的很令人不安，因为我发现它会淹没日志，所以我看不到任何其他内容（也会消耗资源）。 为什么它发生在（一些）Kafka Streams内部主题上，而不是其他主题上？ 我怎样才能禁用它？
-
在深入学习Kafka之前，需要先了解topics, brokers, producers和consumers等几个主要术语。 下面说明了主要术语的详细描述和组件。 在上图中，主题(topic)被配置为三个分区。 分区1(Partition 1)具有两个偏移因子和。分区2(Partition 2)具有四个偏移因子,,和，分区3(Partition 3)具有一个偏移因子。replica 的id与托管它
-
我写了一个kafka流代码，使用kafka 2.4 kafka客户端版本和kafka 2.2服务器版本。我的主题有50个分区 我的Kafka流代码有选择键（）DSL操作，我有200万条记录使用相同的KEY。在流配置中，我已经完成了 因此，我能够使用完全相同的键使用不同的分区。如果我没有按预期使用轮循机制，我的所有消息都会转到同一分区。 直到现在一切都很好，但我意识到；当我使用RoundRobin分
-
在Spring Boot应用程序中，我试图配置Kafka流。用简单的Kafka主题，一切都很好，但我无法得到工作SpringKafka流。 这是我的配置： 我想创建一个基于主题的流。应用一个简单的转换并将此流中的消息发送到test主题。 我向发送以下消息，其中是我自己的复杂类型，但是我现在不知道如何将它转换为中的，以便能够在中使用它。 请建议如何使其工作。
-
我对流媒体有一个普遍的问题，但对于问题的范围，让我们限制自己使用Kafka Streams。让我们进一步缩小范围，将我们的问题局限于单词计数，或者可能是一般的计数。假设我有一个由某个键和一个值组成的流，键可以是一个字符串（假设我们可以有很多字符串，除了空字符串，由世界上的任何字符组成），值是一个整数，现在我们正在构建一个单词计数应用程序，如果词汇表中的单词总数是一万亿，我们不能将它们存储在本地缓存
-
在这部分内容中我们将探索下像Backbone.js这类框架如何适应JavaScript应用架构。通常，开发者创建桌面和服务器类应用有丰富的设计模式供他们去选择，但是，在过去的仅仅几年中，这些模式已经应用到了客户端开发中。 在开始探索任何JavaScript框架之前，非常有必要先认知一下设计模式原理。 MVC，MVP和Backbone.js 设计模式可以解决通用开发问题，可以引导开发者给他们的应用增