我在Python脚本中有以下代码kafka_producer.flush()
信息:根:完成！INFO:kafka.producer.<
浏览 6提问于2020-11-06得票数 1
我使用syncsend=false，我想设置一些超时时间，这样附加器就不会等待这么长时间。 您能告诉我如何配置KafkaAppender才能防止这种等待吗？
浏览 56提问于2020-08-06得票数 0
我试图在我的本地机器上用java 11安装kafka 3.1.0。但是，在列出现有主题的同时，我得到了超时异常。步骤如下：
C：\kafka_2.
浏览 4提问于2022-02-20得票数 0
回答已采纳
尝试用kafka-consumer-perf-test.sh在Kafka中进行性能测试，并且总是得到以下错误：
./kafka-consumer-perf-test.sh --topic perf_test --broker-list $myhost:9092 --messages 10000000 --threads
浏览 1提问于2019-12-16得票数 1
spark版本是2.2.0伪代码：从kafka阅读data2，10分钟窗口和5分钟幻灯片持续时间执行一些agg并写入mysqlinternals.AbstractCoordinator: [Consumer clientId=consumer-3, groupId=dashboard] (Re-)joining group
在窗口时间戳，只做kafka
浏览 62提问于2019-07-19得票数 0
回答已采纳
我在我的应用程序中使用Apache Drill (1.14) JDBC驱动程序，它使用来自Kafka的数据。我在https://drill.apache.org/docs/kafka-storage-plugin/上按照Apache Drill存储插件文档将Kafka插件配置到Apache Drill中 在这个问题上的任何帮助都是非常感谢的: Failed to construct kafka consumer
at org.apache.kafka</em
浏览 42提问于2019-06-12得票数 0
但是，当我使用带有运行代理地址的脚本kafka-consumer-groups.sh作为引导服务器时，我会得到以下错误。kafka@mirror-maker-0:/opt/kafka/bin$ /opt/kafka/bin/kafka-consumer-groups.sh --bootstrap-server <node-ip(org.apache.kafka.clients.NetworkClient)
E
浏览 16提问于2022-03-14得票数 1
我使用Spring进行依赖注入，我有一个恰好是Kafka生产者服务的bean，它通过属性文件获得它的配置，如zookeeper服务器等。import kafka.utils.ZKStringSerializer$;import org.I0Itec.zkclient.ZkClientorg.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.clients.pr
浏览 0提问于2018-04-18得票数 0
4回答
由于卡夫卡制作人的各种原因，我经常得到超时异常。目前，我正在使用生产者配置的所有默认值。我看到了以下超时异常：
1. Set 'retries' c
浏览 2提问于2019-02-20得票数 8
回答已采纳
包含所有“运行状况”指标的HealthEndpoint.invoke (db、磁盘空间...)如果Kafka关闭，则不会响应。因此，在这种情况下，我无法获得任何健康指标。
浏览 21提问于2019-02-01得票数 1
skynet-large-stage,5] on broker 0: Shrinking ISR for partition [skynet-large-stage,5] from 2,0 to 0 (kafka.cluster.Partitionskynet-large-stage,37] on broker 0: Shrinking ISR for partition [skynet-large-stage,37] from 1,0 to 0 (kafka.cluster.Partitionskynet-large-stage,13] on broker
浏览 45提问于2017-02-21得票数 11
回答已采纳
卡夫卡在开始的时候抛出一个异常，我增加了config/server.properties连接超时，但仍然存在问题。这里使用的是Os窗口。Prepare to shutdown (kafka.server.KafkaServer)
kafka.zookeeper.ZooKeeperClientTimeoutException: Timedat kafka.zookeeper.ZooKeeperClient$$anonfun$kafka</em
浏览 0提问于2018-09-05得票数 0
回答已采纳
我正在使用Flink DataStream API中的DataStream类来实现像用例这样的超时。场景如下:我有一个输入kafka主题和一个输出Kafka主题，一个服务从输入主题读取它(在可变的时间内)，然后在输出kafka主题中发布响应。现在要实现超时(必须使用Flink datastream )，我有一个从kafka输入主题读取的FlinkKafkaConsumer，以及从kafka输出主题读取的另一个FlinkKafkaConsumer我正在连接这两个流，并使用
浏览 1提问于2020-09-15得票数 0
回答已采纳
SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=****";'
.write \.option("kafka.sasl.mechanism", "PLAIN") \.option(&qu
浏览 1提问于2018-12-13得票数 5
回答已采纳
我注意到，当我的Kafka流应用程序有一段时间没有阅读来自Kafka主题的新消息时，它就停止工作了。这是我第三次看到这种情况发生。我使用Kafka 1.1.0和<e
浏览 0提问于2018-04-05得票数 0
1回答
我正在使用Kafka，并试图使用其中的数据。从下面这条线，我可以对Kafka的数据进行投票。ConsumerRecord<byte[], <byte[]> record : records) { }我的问题是，与提供200作为超时相比，提供Long.MAX_VALUE作为超时有什么好处。谁能给我解释一下高超时和低超时的区别，哪一个应该在生产系统中使用？
浏览 2提问于2016-12-08得票数 15
回答已采纳
1回答
我尝试在Amazon EMR上运行Spark + Kafka集成，使用spark-shell的一个简单示例，但我不断收到超时错误。但是，当我使用org.apache.kafka和下面相同的设置发布时，它可以正常工作。超时错误： org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms." -> s"$host:$port",
&quo
浏览 31提问于2020-07-09得票数 0
Kafka 0.8.2：request.timeout.ms在将错误发送回客户端之前，代理将等待尝试满足request.required.acks要求的时间量。Kafka 0.11.0：request.timeout.ms配置控制客户端等待请求响应的最大时间。如果在超时之前没有收到响应，客户端将在必要时重新发送请求，或者在重试次数耗尽时使请求失败。
浏览 2提问于2017-09-15得票数 3
我们在Kafka中只启用了ssl加密。客户端身份验证已关闭。 我们有一个spring boot应用程序连接到它。现在, 我们已经设置了 spring.kafka.security.protocol = "SSL“ 尽管如此，我们仍然得到Kafka侦听器端点注册表超时异常 spring Kafka连接到Kafka需要哪些配置
浏览 33提问于2020-06-19得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
