回答情况：
提问时间：
问题标签：
最近，在一次采访中，我被问到一个关于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
回答已采纳
-6c54bdf8c4-ktjkg 1/1 Running 5 13mservice/ingress-aef7dfa8ffc7dc6099c8c10a74d8e9621 1 1 13m
r
浏览 20修改于2019-03-11得票数 1
基于，我在application.properties中尝试了以下配置：
kafka.bootstrap.servers=broker-0-8c8cph49mx2p2wqy.kafka.svc01.us-south.eventstreams.cloud.ibm.com:9093,broker-4-8c8cph49mx2p2wqy.kafka.svc01.us-south.eventstreams.cloud.ibm.com:9093,broker-3-8</em
浏览 10修改于2020-06-20得票数 5
回答已采纳
/tmp/kafka/kafka.tgz --strip 1:#8 0.916 Dload Upload Total Spent Left Speed100 68.0M 100 68.0M 0 0 936k 0
浏览 12提问于2021-09-21得票数 7
_$2” >> /opt/kafka/prometheus/kafka-0-8-2.yml
echo “— pattern : kafka.consumer<type=consumer-fetch-manager-metrics, client-id=(.+)><>(.+):\w* name: kafka_consumer_$2” >> /opt/kafka/prome
浏览 4修改于2019-10-28得票数 3
回答已采纳
unction _cgo_52d112b951a8_Cfunc_rd_kafka_AdminOptions_destroy: error: undefined reference to 'rd_kafka_AdminOptions_destroy'
bazel-out/k8-fastbuild/bin/external/com_github_confluentinc_confluent_kafka_go/kafka&#
浏览 14提问于2019-04-16得票数 6
回答已采纳
608 kafka-python-2.0.2-1602a64f-c1d3-43ea-9090-bef8ac9ce411 /88.88.30.213 kafka-python-2.0.2-596a8b98-ef88-4a9f-8509-3a6432f8b693 /88.88.55.176 kafka-python-2.0.2
a_group a_topic2 kafka-python-2.
浏览 10修改于2022-09-27得票数 0
PORT(S) AGENAME READY STATUS RESTARTS AGEkafka-77486f<em
浏览 0修改于2020-10-02得票数 0
应用程序属性：spring.kafka.template.default-topic=distitopicspring.kafka.producer.value-serializer
浏览 25修改于2019-07-09得票数 1
我们想增加折叠线：以及： "version" : 8, "cluster_name" : "HDP",
"
浏览 0修改于2018-05-26得票数 0
回答已采纳
2019-08-12 10:54:30 - [ERROR] [kafka-producer-network-thread | c8-max-view-live-1-StreamThread-1-producer] [org.apache.kafka.clients.producer.internals.Sender.run:235] : [Producer clientId=c8-max-view-live-| c8-max-view-live-1-StreamThread-1-producer] [or
浏览 0提问于2019-08-12得票数 0
我有一个Kafka主题设置，并试图在Hive中创建一个外部表来查询Kafka流。 ("kafka.topic" = "connect-test", "kafka.bootstrap.servers"="mykafka:9092","kafka.group.id"="1")
INFO : Completed co
浏览 0修改于2019-04-26得票数 3
回答已采纳
= kafka.TopicPartition('my_topic', 0)kafka_partition2= kafka.TopicPartition('my_topic', 6)
kafka_partition7 = kafka.TopicPartition('my_topic'
浏览 3提问于2021-02-04得票数 0
must be in ARN format or "*"作为我在此配置下传递的值： Action: - 'kafka-cluster:DescribeTopic'
- 'kafka-cluster:DescribeGroup'- '
浏览 5提问于2022-01-31得票数 0
: kafka replicas: 1 matchLabels: k8s-app: kube-dns metadata: app: kafka spec: replicas: 1 matchLabel
浏览 4修改于2020-05-18得票数 2
-0-8:2.0.2 pyspark-shell'sc.setLogLevel("WARN")
2.-0-8-assembly, Version = 2.4.3.2.1.0，我用os.environ['PYSPARK_SUB
浏览 0修改于2020-01-05得票数 0
50.063] WARN [kafka-producer-network-thread | streams-pipe-455df74a-b0ca-4612-8df0-c582a6f779b3-StreamThread455df74a-b0ca-4612-8df0-c582a6f779b3-StreamThread-1-producer] [org.apache.kafka.clients.producer.internals.Sender.warn455df74a-b0ca-4612-8df0-c582
浏览 0修改于2018-03-05得票数 2
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号