回答情况：
提问时间：
问题标签：
最近，在一次采访中，我被问到一个关于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
回答已采纳
我在一次面试中被问到这个问题。面试官告诉我，假设存在一个函数--比如getNextWord() --返回给定文档中的下一个单词。另外，我想multimap在内部是作为2-3树实现的，所以要使multimap解决方案成为通用的，我还需要对2-3树进行编码。
虽然我确实想到了尝试，但在面试中实施一项对我来说是不可能的。
浏览 8修改于2012-06-20得票数 1
回答已采纳
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
回答已采纳
这是面试问题的一部分，在第二部分变得更加困难。现在，I给了k 2-3棵树(T1，T2，T3...Tk)，它们具有相同的精确条件，并且知道h_1<=h_2<=...<=h_k和没有三棵树有相同的高度来加入O(h_k-h_1+k)。
浏览 0修改于2020-12-17得票数 0
回答已采纳
1)第一次迭代：Kafka本身具有流媒体、负载均衡和容错能力。在这种情况下，在考虑Kafka集群时，应该在开始时描述broker计数和分区。它本身并不是扩张的东西。这个问题的重点是负载均衡器看起来仍然需要，尽管Kafka是如此强大的候选者。
我的第二种方法类似于下面的模式。(在此期间，我在这次面试之前遇到过一些面试官，他们准确地将负载均衡器命名为“过时的技术”，我被评判为非常残酷，因为我建议使用负载均衡器。)如果你是一位Kafka
浏览 34提问于2020-02-06得票数 2
回答已采纳
我有一个代理运行在我的本地机器与Windows操作系统，其中有2-3个主题与消息存储。我想通过增加两个代理实例来扩展我的机器。通过创建不同的属性文件，我遵循了在相同的机器上配置3个代理的所有步骤。2019-07-11 13:56:33,580信息停止在dir C中服务日志：\kafka_2.12-2.2.1\data\kafka (kafka.log.LogManager) 2019-07-1113:56:33,585错误关闭代理，因为C:\kafka_2.12-2.2.1\data\kafka<
浏览 1修改于2019-07-11得票数 0
我第一次面试Java开发人员的角色，特别是RMI、Serverlet和JDBC。我想问的是，如何在2-3天内更新所有内容，特别是针对Java的OOP概念(多态性、继承)？感谢所有人
浏览 2提问于2009-07-10得票数 10
回答已采纳
当我在我的Kafka生产者中配置了对所有ACKs=all的确认，并且min.insync.replicas=2，replicas.factor=3，并且在同步列表中只有2个代理isr=2-3 (考虑到代理
浏览 8提问于2020-01-20得票数 1
1回答
我的节目采访由3名面试官组成，每次45分钟。前两位面试官给了我2-3个简短的编码问题(即反向链接列表，使用rand(5)等实现rand(7) )，第三位面试官用整段时间来回答单个问题：
我的问题是:你认为这个问题适合在白板上大约编码。40分钟？
浏览 6修改于2013-05-26得票数 4
我想为面试目的对候选人进行在线筛选，问题类型包括：编码问题需要回答的问题只有2-3行。
我想提出自己的问题。用户需要注册使用电子邮件id，并参加测试。对此有什么好的建议？
浏览 0修改于2022-11-15得票数 0
我试图用这样的测试数据填充kafka主题： Properties properties = new Propertiesproperties.put("bootstrap.servers", "192.168.0.2:9092");
properties.put("key.serializer", "org.apache.kafka.common.serialization.StringSeri
浏览 0修改于2019-03-27得票数 0
在mesos上使用spark与kafka和cassandra ( spark- cassandra -connector)结合使用spark-streaming我正在听一个kafka主题，然后使用.saveToCassandra插入到cassandra中
我有60个CPU分配给spark (30个spark节点和5个cassandra节点)，我正在尝试遵循apache spark的建议“一般来说，我们建议集群中每个CPU核心2-
浏览 0修改于2019-08-07得票数 1
如果我有一个Kafka主题，其中我只有一个partitionP0，而生产者使用不同的keysk1，k2将数据写入partitionP1。假设1-1,1-2是关键字k1的值，2-1,2-2,2-3是关键字k2的值。我现在在主题的partitionP0中有1-1,1-2,2-1,2-2,2-3 我是否可以有两个不同的consumersC1，C2侦听主题中的partitionP0并读取与C1中不同keys...as关联的值
浏览 18修改于2020-09-25得票数 0
我的flink作业使用FlinkKafkaConsumer010从kafka consumer读取数据，并使用CustomBucketingSink接收到hdfs。我们有一系列的转换kafka -> flatmaps(2-3个转换) -> keyBy -> tumblingWindow(5 mins) -> Aggregation -> hdfsSink。以下是我的假设：
Flink从kafka消耗一些固定数量的事件(一次从多个分区获得多个偏移量)，并等待，直到它到达接收器，然后是检查点。在成
浏览 0修改于2020-03-13得票数 0
我正在用Kafka流(v0.10.0.1)编写一个应用程序，并希望通过查找数据丰富我正在处理的记录。此数据(时间戳文件)每天写入HDFS目录(或每天2-3次)。我如何在Kafka Streams应用程序中加载它并连接到实际的KStream？更新
正如建议的那样，卡夫卡连接将是一条出路。由于查找数据是在关
浏览 4修改于2016-09-05得票数 6
回答已采纳
我使用的是Kafka 2.0.0，有一些__consumer_offsets主题的分区是500-700 GB，超过5000-7000个段。这些部分超过2-3个月。日志中没有错误，该主题默认是紧凑的。或者可能是kafka 2.0.0的一个bug？我能做些什么检查？
浏览 58修改于2021-06-03得票数 0
背景：另外，也许一些基本的ADO.NET资源也是不错的。我面试的公司还没有升级到SQL3.5，所以LINQ to .NET和Entity Framework将不可用。我真的不确定面试时是否需要这么多，但还是很高兴知道。
浏览 0修改于2013-08-20得票数 0
我有一个结构化的流式作业，从kafka读取，执行聚合和写入hdfs。该作业在yarn中以群集模式运行。我使用的是spark2.4。每隔2-3天，这项工作就会卡住。它不会失败，但会卡在某个微批处理中。
浏览 34提问于2020-10-03得票数 0
我们有多项式Kafka 1.0.1集群(也尝试了早期版本)，当我们创建这个集群时，我们将复制作为n-1，所以如果我们有7节点，我们给6作为复制因子，但并不是所有的副本都变成ISR。如果我们重新创建多项式簇2-3次，它将为所有副本创建ISR。有没有人在这方面得到了类似的帮助，非常感谢。
浏览 0修改于2018-03-26得票数 0
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号