回答情况：
提问时间：
问题标签：
最近，在一次采访中，我被问到一个关于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
回答已采纳
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
回答已采纳
使用Spring Boot Kafka -v 2.2.1.RELEASE (使用kafka-clients.jar v 2.3.1) 我正在为我的Kafka代理使用confluent v5.1.2。我有一个基于spring的监听器类(@KafkaListener)，每个消息处理大约需要6-7秒，因为它是一个资源密集型操作。
浏览 20修改于2020-01-31得票数 0
1)第一次迭代：Kafka本身具有流媒体、负载均衡和容错能力。在这种情况下，在考虑Kafka集群时，应该在开始时描述broker计数和分区。它本身并不是扩张的东西。这个问题的重点是负载均衡器看起来仍然需要，尽管Kafka是如此强大的候选者。
我的第二种方法类似于下面的模式。(在此期间，我在这次面试之前遇到过一些面试官，他们准确地将负载均衡器命名为“过时的技术”，我被评判为非常残酷，因为我建议使用负载均衡器。)如果你是一位Kafka
浏览 34提问于2020-02-06得票数 2
回答已采纳
我们正在运行一个Flink 1.15.2集群，其作业具有Kafka Source和Kafka Sink。我们的警报机制通知我们，消费者延迟是在30个分区中的一个分区上建立起来的。由于Flink做了自己的偏移量管理，我们没有办法(通过Flink或Kafka控制台工具)找出分配分区的TaskManager。
浏览 8提问于2022-11-01得票数 0
我有一个具有以下版本的业务应用程序
spring-cloud-stream-binder-kafka(2.2.1-RELEASE)spring-cloud-stream-binder-kafka-streams(3.0.3-RELEASE)
我们有大约20个batches.Each批处理，使用6-7个主题来处理business.E
浏览 1修改于2020-04-28得票数 0
回答已采纳
四组数据转换为json 1-2=3.4=0 6-7=8=0 10-11=12=13 14-15=16=0的不同格式a:,"1-2" a:,"6-7" a:,"10-11" c:, "0" c:,"0"
浏览 5提问于2021-07-14得票数 0
回答已采纳
7 hrs", "6-7 hrs", "12-13 hrs", "14+ hrs", "6-7 hrs", "2-3 hrs",
"6-7 hrs", "4-5 hrs", "8-9 hrs", "67 hrs", "6-7 hrs", "10-11 hrs", "1
浏览 0提问于2018-02-10得票数 0
我尝试过创建一个DStream，它给出了case类的DStream，这是我使用foreachRDD在DStream上保存到Cassandra中的，但是每隔6-7天就会挂起。import spark.implicits._ .readStream .option("kafka.bootstrap.servers", "brokerIP:po
浏览 0修改于2022-08-12得票数 0
1回答
嗨，我在做一个简单的数字匹配时遇到了问题，我做错了什么：1) Always anchor to start3) Always Followed我尝试了几种方法：(不匹配)^[0-9]{6-7}_^[\d]{6}_我得到了匹配，为什么我不能在这个表达式中做可变长度？
浏览 0提问于2012-07-05得票数 2
回答已采纳
所以我想但使用适当的小于/大于或等于符号forest( ..... slab=txt ...)所以运行正常，因为"1 <= 2“是一个正确的R表达式，但这不是我想要的。我只想
浏览 0提问于2014-01-03得票数 1
我的数据库在服务器端有6-7个表。我只想要几个10-50的客户名单，这是通过存储过程(通过连接6-7表选择记录)我。
我创建了应用程序(用于在线和离线环境)，这是从服务器到客户端的同步表，反之亦然。但这6-7个表包含了大约67k的巨大记录。我不想同步那张6-7表。我想要同步的客户名单只为每个登录用户。
浏览 3修改于2013-08-29得票数 0
当我拨打twilio号码时，电话会前转，但在放弃之前只会振铃6-7次。这是意想不到的，因为timeout属性的默认值是30秒。行为是不变的-呼叫在6-7次振铃后仍然放弃。
在放弃之前，如何将twilio呼叫前转设置为振铃时间超过6-7次？
浏览 3提问于2018-07-18得票数 0
我的Jenkins安装程序有300+自动测试，并且可以访问6-7个节点。所以，当我运行Jenkins作业时，有没有办法将300+测试的负载分布到现有的6-7个节点上，并同时执行它们呢？
浏览 6提问于2022-10-15得票数 0
我有大约6-7个不同的动作，在相同的控制器，在每个视图加载被击中。我现在是这样做的： { :age => p.age上面的代码片段是在我的控制器内的6-7操作中编写的，这相当于我需要在上面显示name和age的6-7视图。
浏览 1修改于2020-06-20得票数 0
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号