回答情况：
提问时间：
问题标签：
最近，在一次采访中，我被问到一个关于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
回答已采纳
1)第一次迭代：Kafka本身具有流媒体、负载均衡和容错能力。在这种情况下，在考虑Kafka集群时，应该在开始时描述broker计数和分区。它本身并不是扩张的东西。这个问题的重点是负载均衡器看起来仍然需要，尽管Kafka是如此强大的候选者。
我的第二种方法类似于下面的模式。(在此期间，我在这次面试之前遇到过一些面试官，他们准确地将负载均衡器命名为“过时的技术”，我被评判为非常残酷，因为我建议使用负载均衡器。)如果你是一位Kafka
浏览 34提问于2020-02-06得票数 2
回答已采纳
| 1/1/2020 | bbb | 2/1/2020 <br>还有更多的列，但我暂时忽略它们。我想创建一个视图来找出"aaa“向下钻取到面试日期和当前状态的面试次数。问题是，
浏览 2修改于2020-02-21得票数 0
kafka.common.LeaderNotAvailableException (kafka.producer.BrokerPartitionInfo) [2015-10-23 10:49:25,026]: class kafka.common.LeaderNotAvailableException (kafka.producer.BrokerPartitionInfo) [2015-10-23 10]: class kafka
浏览 0修改于2015-10-23得票数 0
/spark/spark-streaming-kafka-0-10/2.2.0/spark-streaming-kafka-0-10-2.2.0.pom
-- artifact org.apache.spark#spark-streaming-kafka-0-10;2.2.0!org.apache.spark#spark-streaming-kafka-0-10;2.2.0!.maven.o
浏览 22提问于2018-08-27得票数 6
回答已采纳
1回答
fastlane_accounts_service_subscriber_kafka.1.yoh6ytisqt3x@ip-10-0-1-109.ap-southeast-1.compute.internal@ip-10-0-1-109.ap-southeast-1.compute.internal | /app/vendor/bundle/ruby/2.5.0/gems/ruby-kafka-0.7.2connection to ip-
浏览 1提问于2018-10-21得票数 0
回答已采纳
[test]: class kafka.common.LeaderNotAvailableException (kafka.producer.BrokerPartitionInfo)[2015-10-19 15:class kafka.common.LeaderNotAvailabl
浏览 9提问于2015-10-19得票数 8
回答已采纳
:10:24 GMT kafka-node:KafkaClient broker is now readyTue, 22 Oct 2019 10:10:24 GMT kafka-nod
浏览 4提问于2019-10-22得票数 2
-9d6b81206f5d1d7d.elb.us-east-2.amazonaws.com 31090:30366/TCP 10mkafka-cp-kafka ClusterIP 10.100.163.1588083/TCP 10m
k
浏览 4修改于2020-07-05得票数 0
通常，在kafka集群划痕安装之后，我在/data/ kafka -log(kafka日志)下面看到了这个文件。所有主题都应放在哪里)-rw-r--r-- 1 kafka hadoop 0 Jan 9 10:07 cleaner-offset-checkpointdrwxr-xr-x 2 kafk
浏览 0提问于2020-01-10得票数 0
回答已采纳
ThrottledChannelReaper)kafka_1 | [2022-06-13 22:08:10,121] INFO Loading logs from log dirs ArraySeq(/kafka&
浏览 26提问于2022-06-13得票数 0
回答已采纳
-25 10:26:55,944] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration)[2020-02-25 10:26:56,515] INFO Connecting)
[2020-02-25
浏览 6提问于2020-02-25得票数 0
回答已采纳
： kafka-clients-2.7.0.jar spark-token-provider-kafka-0-10_2.12--2.7.0.jar,file:///C://Users//shivani//Desktop//Spark//spark-sql-kafka-0-10<
浏览 30修改于2021-07-02得票数 1
回答已采纳
name bufferpool-wait-time (org.apache.kafka.common.metrics.Metrics)[2017-01-31 10:06:50,467] DEBUG Starting Kafka producer I/O thread.(org.apache.kafka.clients.producer.internals.Sender)
[2017-01-31 10:06:50
浏览 0修改于2017-01-31得票数 2
回答已采纳
)kafka_1 | [2015-09-01 10:44:16,817] INFO [Kafka Server 32773], starting (kafka.server.KafkaServer)
kafk
浏览 1修改于2015-09-01得票数 8
-08 06:07:13,123 INFO Kafka Connect stopping (org.apache.kafka.connect.runtime.Connect) [Thread-10]2021-10-08 06:07:13,131 INFO REST server stopped (org.apache.kafka.connect.runtime.rest.RestServerstopping (org.apache.kafka
浏览 0修改于2021-10-08得票数 0
回答已采纳
标题-名称划分-编号例如：- Ajinkya-0，Ajinkya-10，Ajinkya-12等.[2018-10-27 15:09:19,917] INFO [Log partition=__consumer_of
浏览 1修改于2018-10-27得票数 0
回答已采纳
启动Kafka-Connect时，我看到了很多警告 10:33:56.706 [DistributedHerder] WARN org.apache.kafka.clients.admin.AdminClientConfigbut isn't a known config.
10:33:56.708 [DistributedHerder] WARN org.apache.kafka.clients.admin.AdminClientConfig' was supplied but
浏览 595修改于2019-04-01得票数 18
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号