回答情况：
提问时间：
问题标签：
最近，在一次采访中，我被问到一个关于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
回答已采纳
-- With bootstrap server--bootstrap-server b-1.bhuvi-cluster-secure.jj9mhr.c3.kafka.ap-south-1.amazonaws.com:9098,b-2.bhuvi-cluster-secure.jj9mhr.c3.kafka.ap-south-1.amazonaws.com:9098 \--topic debezium-my-topic \
--command-co
浏览 24提问于2021-08-26得票数 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
回答已采纳
-4c8b-b4b1-1db2c788b1a9-9, transactionalId=tx-ks_batch-file-to-kafka-ff42f0cb-e437-4c8b-b4b1-1db2c788b1a9-4c8b-b4b1-1db2c788b1a9-9, transactionalId=tx-ks_batch-file-to-kafka-ff42f0cb-e437-4c8b-b4b1-1db2c788b1a9-4c8b-b4b1-1db2c78
浏览 5修改于2022-05-08得票数 1
confluentinc/cp-schema-registry:4.0.0 "/etc/confluent/dock…" 9 hours ago Up 9 hours"/etc/confluent/dock…" 9 hours ago Up 9 hours 0.0.0.0:9092-9093->9092-9093/tcpk1
9<
浏览 0修改于2018-04-24得票数 3
回答已采纳
6 kafka-python-2.0.2-50435c75-9f50-4053-b6d1-5b0c0a59a927 /88.88.49.27 kafka-python608 kafka-python-2.0.2-1602a64f-c1d3-43ea-9090-bef8ac9ce411 /88.88.30.213 kafka-python2 kafka-python-
浏览 10修改于2022-09-27得票数 0
:9092: i/o timeout2020-12-30T09:55:37.896+0900 INFO kafka/log.go:36producer/le
浏览 3修改于2020-12-30得票数 0
回答已采纳
我被这两个密码卡住了。int f(int n){ return 1; return f(n-1) + f(n-1);代码2 (平衡二叉树) if(node == null){ }}代码2为O(N)
我不知道这两个密码有什么不同。看
浏览 8修改于2017-07-21得票数 4
回答已采纳
= kafka.TopicPartition('my_topic', 0)kafka_partition2= kafka.TopicPartition('my_topic', 2)
kafka_partition3 = kafka.TopicPartition('my_topic'
浏览 3提问于2021-02-04得票数 0
at kafka.Kafka$.main(Kafka.scala:85)下面是我的启动脚本 if [ -n "$pid" ] kill -9 $pid echo "$NAMEversion "1.8.0"
浏览 4修改于2018-04-24得票数 1
1回答
I无法让它与弹簧云流绑定-kafka:1.2.0MESSAGE (e23885fd-ffd9-42dc-ebe3-5a78467fee1f) SENT : GenericMessage [payload=..., kafka_offset=36,
id=448175f5-2b21-9a44-26b9-85f093b33
浏览 3修改于2017-06-15得票数 3
回答已采纳
13回答
【有奖问答】程序生涯中有哪些记忆犹新的面试体验？（已完结）
腾讯云开发者社区、程序人生、工作、开发者、面试
也欢迎大家持续补充分享你那记忆犹新的面试体验~是紧张出错的面试现场？还是让你哭笑不得的面试题目？又或者是那位专业严谨的面试官？ ● 活动时间：2024年4月3日～2024年4月9日，本次互动截至到2024年4月9日
浏览 1050修改于2024-04-10
17,335] INFO [GroupCoordinator 2]: Member consumer-32-be8807df-b88f-4cc9-bddf-bed772d1244f in group kafka-consumer-group-x17,335] INFO [GroupCoordinator 2]: Member consumer-31-4dd9cb6e-09e9-47db-9610-37e0ab5633e0 in group kafka-consumer-group-x18,636] INF
浏览 3修改于2019-01-14得票数 3
<clinit>(RocksDB.java:35) at java.lang.J9VMInternals.initialize(J9VMInternals.java:236) at java.lang.J9VMInternals.initializeImpl(
浏览 0提问于2017-03-31得票数 0
java.lang.String] to [com.kconsumer.accountconsumer.domain.Account] for GenericMessage [payload={"id":"5b079d0b340d9ef2ac9b6f02@6a0a6b0b, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=5b079d0b340d9ef2ac9b6f02, kafka
浏览 0修改于2018-05-25得票数 7
回答已采纳
我正在尝试连接到一台Kafka服务器。的配置，但我得到了错误： INFO: AdminClientConfig values: Jan 22, 2021 9:, 2021 9:48:01 PM org.apache.kafka.common.utils.AppInfoParser$AppInfo <init>
INFO: Kafka commitId: 448719dc99a19793Jan 22, 2021
浏览 34修改于2021-01-23得票数 0
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号