回答情况：
提问时间：
问题标签：
最近，在一次采访中，我被问到一个关于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
回答已采纳
(kafka.log.LogManager)[2015-08-27 11:03:01,848] INFO Logs loading complete.n (kafka.server.KafkaRequestHandlerPool)
[2015-08-27 11:03:02,128] INFO [Kafka Request Handler
浏览 1提问于2015-08-27得票数 0
回答已采纳
卡夫卡荚原木：2020-07-06T1111:22:40.51 INFO ==> ** Starting Kafka setup **
2020-07-06T11:22:40.55379314Z 11:22:40.55 WARN =11:22:40.56 I
浏览 5修改于2020-07-07得票数 1
(kafka.log.LogManager)[2018-11-02 16:00:07,388] INFO Awaiting socket connections on 0.0.0.0:9092.(kafka.network.Acceptor)
[2018-11-02 16:00:07,4
浏览 3修改于2018-11-03得票数 7
kafka服务器日志：[2016)[2016-01-11 1201-11 12:15:17,515] INF
浏览 0修改于2018-05-18得票数 3
我们有Linux流变机器7.2，在/kafka/topics下面有以下文件夹drwxr-xr-x 2 root kafka 141 May 11 17:19 bgol.ase.fgt.dad3-10
drwxr-xr-x 2 root kafka 141May 11 17:19 bgol.ase.fgt.
浏览 0修改于2021-05-11得票数 -3
| SYSADMIN || 2020-06-26 01:11:22.082 -0700 | MONITOR| 2020-06-26 01:11:22.082 -0700 | REFERENCE_USAGE | DATABASE |
浏览 6提问于2020-06-26得票数 0
回答已采纳
1回答
我们有5个节点的kafka-cluster，2.3.0 Kafka版本kafka_2.12-2.3.0运行OpenJDK11。 从上周开始，集群中的一个代理突然出现故障。2021-01-27 11:26:59,472 INFO kafka.controller.KafkaController: [Controller id=5] Resigned at kafka.utils.ShutdownableThread.run(Shut
浏览 86提问于2021-02-01得票数 0
TO ROLE "KAFKA_CONNECTOR_ROLE_1"; **10126** [2021-12-16 11:19:20,700] INFO [Worker clientId=wflakeSinkServiceV1:81) 10097 [SF_KAFKA_CONNECTOR] uploadWithoutConnection:63)
10098 [2021-12-16
浏览 3修改于2021-12-20得票数 0
以下是我在kafka重启时从logstash得到的日志：[2019-11-25T11:42:12,481][WARN ][org.apache.kafka.clients.NetworkClient]Broker may
浏览 0提问于2019-11-25得票数 0
=__transaction_state-11, dir=/kafka/logs] Rolled new log segment at offset 807760 in 4 ms.-11 in dir /kafka/logs due to IOException (kafka.server.LogDirFailureChannel)
java.nio.file.NoSuchFileException: /kafka/logs&#
浏览 0提问于2019-01-11得票数 3
)[2017-11-22 11:59:35,120] INFO Connecting)
[2017-11-22 11:59:35,140] INFO Client environment:java.class.path=:/opt/kafka/bin/..(Kafka</
浏览 5修改于2017-11-22得票数 0
回答已采纳
我尝试从kafka服务器流式传输数据到spark。正如你猜的那样，我失败了。我使用的是spark 2.2.0和kafka_2.11-0.11.0.1。with capacity 897.6 MB17/11/01:114)
at kafka.consumer.SimpleConsumer.liftedTree1$1(Sim
浏览 2修改于2017-11-01得票数 1
/kafka-console-producer.sh --broker-list <broker_list> --topic test-1
[2014-04-22 11:58:48,445] WARN Error whilefor topic: test-1 (kafka.producer.async
浏览 6修改于2017-10-11得票数 67
)[2021-10-11 19:05:18,332] INFO Connecting)[2021-10-11 19:05:18,353)
[2021-10-11 19:09:29,
浏览 714修改于2021-10-11得票数 0
:compileClasspath'.17:11:15,004 ERROR - Searched in the following locations:
17:11:15,004 ERROR -file:/local_
浏览 0修改于2019-02-04得票数 2
回答已采纳
: Starting Kafka producer I/O thread.2017-11-22 22:11:54.484 DEBUG 8988 --- [ad | producer-1] org.apache.kafk
浏览 9修改于2017-11-22得票数 1
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号