回答情况：
提问时间：
问题标签：
最近，在一次采访中，我被问到一个关于Kafka Streams的问题，更具体地说，面试官想知道为什么/什么时候你会使用Kafka Streams DSL而不是普通的Kafka Consumer API来读取和处理消息流
浏览 2提问于2020-09-13得票数 3
所以我有一个Java服务，它在一个while循环中使用Kafka来获取kafka-clients主题。在执行大约3-5分钟后，我在运行单个使用者时遇到了OOM (内存不足)问题。我捕获了一个堆转储，它指向org.apache.kafka.common.network.Selector占用已分配的内存。最终我得到了GC overhead limit exceeded错误。 Kafka JIRA Debugging a memory leak in Apache Kafka® 以下是我的一
浏览 118修改于2021-11-05得票数 0
在SPEL表达式下面试过，但无法工作。需要帮助！@KafkaListener(topics = "#{Arrays.asList(${kafka.topic.helloworld}.split(',')).stream().map(p -> p+envSuffix
浏览 1修改于2018-03-12得票数 2
回答已采纳
我们使用的是带有3台服务器的kafka集群，它们都有zookeeper。我们有7个主题，每个主题有6个分区。对于每个主题，我们有3个java使用者。当我启动consumer时，将分区分配给使用者几乎需要3-5分钟。当我们停止其中一个消费者并再次启动时，也会遇到相同的行为。我如何控制或减少它？请注意，我使用的是kafka 0.9，适用于新消费者auto.leader.rebalance.enable=true
leader.imbalance.ch
浏览 0修改于2016-08-09得票数 3
1回答
我的朋友在一次面试中被问到这个问题，我们都不知道如何解决这个问题。会很感激你的帮助！在dataframe1中创建了一个列，其中包含两个小时间隔的桶(例如: 3-5下午)在步骤3中创建的“时间桶”列上合并了这些数据格式。
在一次面试中，我不知道最快的方法是什么。
浏览 2提问于2021-02-20得票数 0
回答已采纳
根据我对实时分析的要求，我必须在Kafka中插入1000万张唱片，而且在此基础上，我还必须编写自定义的消费者logic.But来满足这一要求，我如何在3-5分钟内将1000万张唱片植入卡夫卡？
浏览 0提问于2019-05-03得票数 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
回答已采纳
1)第一次迭代：Kafka本身具有流媒体、负载均衡和容错能力。在这种情况下，在考虑Kafka集群时，应该在开始时描述broker计数和分区。它本身并不是扩张的东西。这个问题的重点是负载均衡器看起来仍然需要，尽管Kafka是如此强大的候选者。
我的第二种方法类似于下面的模式。(在此期间，我在这次面试之前遇到过一些面试官，他们准确地将负载均衡器命名为“过时的技术”，我被评判为非常残酷，因为我建议使用负载均衡器。)如果你是一位Kafka
浏览 34提问于2020-02-06得票数 2
回答已采纳
我试图使用基于Google 的Java将数据从kafka安装到BigQuery。数据的长度为JSON行~12K。bigQueryOptions.getService();
我看到每次通话的插入时间为3-从他们的文档中，我担心会影响到每个表的插入配额(我从Kafka流到了大约100万行/分钟)，但现在我很乐意处理这个问题。我一定是做了什么很不对的设置
浏览 3提问于2017-02-24得票数 0
回答已采纳
假设我在php中有这样的数组 "Caracas"=>array( "4","3-5 WorkingDays","Saturday" "sea"=>array(
"18","3-5 Days","Wednesd
浏览 0提问于2012-08-07得票数 0
回答已采纳
我正在从kafka流读取我的spark应用程序中的数据流。我的需求是当用户提出任何请求(搜索/浏览等)时，为他提供产品推荐。
我已经有了一个包含用户分数的训练模型。这个API需要大约3-5秒的时间来生成每个用户的结果，这非常慢，因此我的流处理落后了。有什么方法可以优化这个API的时间吗？我正在考虑将流持续时间从15秒增加到1分钟作为优化(现在还不确定结果)
浏览 2提问于2017-11-14得票数 0
"spark.port.maxRetries" : "100", }
工作进展顺利每一批150秒，我正在处理3-5 k事件。我
浏览 8修改于2020-10-27得票数 2
回答已采纳
to set address.[ 5575.781728] usb 3-5:3-5: Device not responding to set address.
[ 5576.301606] usb 3-5: device not accepting address 104,5577.137411] usb 3-5: Device not responding to set add
浏览 0修改于2015-07-13得票数 0
我使用Confluent的Kafka连接器将数据从Kafka汇到一个MinIO桶中。我在Kubernetes环境中使用io.confluent.connect.s3.S3SinkConnector。因此，为了执行主题添加，我使用了Kafka： configuration = requests.get("http://kafka-connect-cluster-connect-api"config" no
浏览 10修改于2021-03-19得票数 0
回答已采纳
4回答
阵列：var ranges = ["3-5", "1-4", "0-9", "10-10"];ranges.sort();
知道我怎样才能得到想要的输出吗？
浏览 10提问于2015-12-23得票数 4
回答已采纳
3 P 2685 ALFA ROMEO 3-5 ABA NaN7 ALFA ROMEO 35 ABA NaN 879
6 ALFA ROMEO <
浏览 2提问于2016-03-04得票数 1
回答已采纳
"Grades 3-5", "Grades 3-5", "Grades 33-5", "Grades PreK-2",
"Grades 3-5", "Grades 9-12
浏览 0提问于2018-03-21得票数 1
我有一台table11 Fred Lapinski brook st. 3-53 David Leterman blue st. 3-5和Table2
id name
浏览 7提问于2019-11-25得票数 0
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号