回答情况：
提问时间：
问题标签：
最近，在一次采访中，我被问到一个关于Kafka Streams的问题，更具体地说，面试官想知道为什么/什么时候你会使用Kafka Streams DSL而不是普通的Kafka Consumer API来读取和处理消息流
浏览 2提问于2020-09-13得票数 3
在SPEL表达式下面试过，但无法工作。需要帮助！@KafkaListener(topics = "#{Arrays.asList(${kafka.topic.helloworld}.split(',')).stream().map(p -> p+envSuffix
浏览 1修改于2018-03-12得票数 2
回答已采纳
在我的Spark Streaming作业中，CPU未得到充分利用(仅5-10%)。
它从Kafka获取数据并发送到DynomoDB或thridparty端点。
浏览 1提问于2017-03-18得票数 0
1回答
我正在从下面试用nxlog kafka out模块。我收到以下错误消息
ERROR Failed to load module from /usr/local/libexec/nxlog/modules/output/om_kafka.so, /usr/local/libexec/nxlog/modules/output/om_kafka.so: undefined symbol: r
浏览 4修改于2015-02-19得票数 1
回答已采纳
Kafka集群有3个代理(版本:1.1.0)，运行时间超过6个月。每次，一个代理在下面的错误日志之后关闭，然后几分钟后，其他两个代理也关闭，具有相同的错误，但其他分区日志文件。-11 in dir /kafka/logs due to IOException (kafka</e
浏览 0提问于2019-01-11得票数 3
我正在尝试开发一个基于IoT的应用程序，其中多个设备将生成数据并将其发送到Kafka broker。这些设备的数量可能在6万到7万左右。可以有5-10种不同的设备类型，但是，每种类型的设备数量将以千为单位，例如每个设备数量为20-4万。
我想了解Kafka主题的用法，它应该支持这么多设备(平均20-4万台设备)。
浏览 5提问于2019-04-04得票数 3
我们有一个用例，基于到达工作队列的工作项，我们需要使用消息元数据来决定从哪个Kafka主题流式传输我们的数据。因此，如果一个工作者有"n“个线程，我们可能会将kafka流打开到"n”个不同的主题。(n通常小于10)。一旦工作进程处理完消息，我们还需要关闭流。工人可以收到下一条消息，一旦它确认了第一条消息，在这一点上，我需要打开另一个主题的kafka流。此外，每个kafka流都需要扫描主题的所有分区(大约5-10个)，以根据某个属性进行过滤。这样的流是否适用于Kafka
浏览 17提问于2020-09-10得票数 0
1)第一次迭代：Kafka本身具有流媒体、负载均衡和容错能力。在这种情况下，在考虑Kafka集群时，应该在开始时描述broker计数和分区。它本身并不是扩张的东西。这个问题的重点是负载均衡器看起来仍然需要，尽管Kafka是如此强大的候选者。
我的第二种方法类似于下面的模式。(在此期间，我在这次面试之前遇到过一些面试官，他们准确地将负载均衡器命名为“过时的技术”，我被评判为非常残酷，因为我建议使用负载均衡器。)如果你是一位Kafka
浏览 34提问于2020-02-06得票数 2
回答已采纳
问题是这些设备每秒会发出5-10个相同值的记录。因此，如果您在kafka主题中看到单个设备的输出，则如下所示：然而，我想在kafka中删除这些作为突发事件出现的重复记录我试图使用Kafka stream API提供的窗口和ktable的概念，但这似乎不太可能。有什么想法吗？
浏览 2修改于2018-07-08得票数 0
我有Spark1.4流应用程序，它从Kafka读取数据，使用状态转换，并有15秒的批处理间隔。所以我的问题是：
元数据检查点的间隔是什么，数据检查点的间隔是什么(意
浏览 2提问于2016-06-09得票数 2
回答已采纳
我有一个结构化的流媒体应用程序，它试图一次从Kafka读取数百万张唱片并处理它们。我的应用程序总是从3个执行者开始，从不增加执行者的数量。火花码val dsrReadStream = spark.readStream.format("kafka")
.option("kafka.bootstrap.servers",
浏览 0修改于2019-04-08得票数 0
回答已采纳
1回答
我使用Spring和Spring作为批处理服务，从Kafka收集数据，直到满足特定条件，然后转储数据。
当数据离开我的服务时，我想确认提交，但它可能会在内存中停留5-10分钟。
浏览 0提问于2018-10-31得票数 0
回答已采纳
运行在kubernetes上的Kafka-Broker。一个SpringBoot-应用程序与kafka-streams和一个输入-主题作为KSteram。假设将来会有更多的键/值对(大约500-1000k)，那么这将需要大约5-10倍的时间 感谢你的帮助
浏览 37提问于2020-09-18得票数 0
回答已采纳
我正在研究Spring实现，我的用例是将Kafka主题的消息作为批处理(使用批处理侦听器)使用。当我使用消息列表时，将迭代并调用REST端点以进行消息充实。因此，当我们重新启动容器时，我会再次得到所有的10条信息还是会接收到5-10条消息？
还是有一种方法可以实现上面的用例？我查看了Spring的所有类型的错误句柄，并需要输入如何实现上述需求。
浏览 4提问于2022-04-20得票数 0
回答已采纳
每个提取查询都是一个复杂的SQL语句，涉及连接等中的5-10个表，有多种原因。大约有20-30份这样的声明。
所有这些提取查询都可能需要每天以不同频率多次运行。我们计划使用Kafka发布一条消息，让Nifi工作流知道无论何时RDBMS表被更新并需要触发流(我不能仅仅基于“增量”列值触发Nifi流，可能只有所有的行更新场景，我们可能不会在表中创建新的行)。
浏览 0提问于2019-02-04得票数 0
ID Write-Output "ID: $ID" 调用它的有效方法的示例如下：CheckUpkeep 1-101-10例输出：编号: 1-3 5-10
如何更新regex，以便捕获逗号，而不必在调用函数(CheckUpkeep " 1-3,5-10 ")时使用字符串引号(无论是单引号还是双引号)，以便在调用1-3、5-10</em
浏览 2修改于2022-02-04得票数 3
回答已采纳
在同一个应用程序中，如果是process1 = Kafka Consumer , process2= Data Analysis and database update logic.process2 is to be executed once every n=60 seconds import sysfrom
浏览 3修改于2015-08-30得票数 3
回答已采纳
带有2个数据的字典的玩具示例： 0 Greg 1-10 'df2': Name Time 1 Jeff 1-10}d = {'df1': pd.DataFrame({'Name': ["Jeff", "Greg"], 'Times': ["1-5", "<e
浏览 4修改于2022-03-17得票数 1
回答已采纳
1回答
df %>% age_c = cut( breaks = c(-Inf, 5, 10), <fct> <fct> <int>2 0-5 50-100 14 5-10 0-50 0
5 5-10 50-100
浏览 0修改于2020-11-11得票数 1
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号