1回答
应用程序部署在1个实例中，num.stream.threads=16。我运行kafka-B.Topic-groups.bat命令来检查线程是如何分配到组中的分区的，得到以下output.Topic A和B，分配了16个线程，其中主题B中的14个线程是空闲的。- - topic-BGroupStreamThread-681-consumer
如何避免topic-B中的空闲线程，或者是
浏览 41提问于2020-02-27得票数 1
回答已采纳
我已经创建了一个多线程Kafka使用者，其中为每个分区分配了一个线程(我总共有100个分区)。然后，我使用下面的代码片段将每个流提交到不同的线程。但是它从其中一个线程中随机挑选一些事件并进行处理，然后另一个线程从另一个分区开始处理。它看起来像是顺序处理，但使用了不同的线程。我希望所有的100个线程都能进行处理。我是不是漏掉了什么？
浏览 24提问于2019-03-01得票数 0
在的下图中，我们可以看到多个使用者任务可以在同一个线程上工作。我的问题是，如果一个应用程序由多个使用者(可以从不同的主题中读取)组成，那么其中一些使用者会在一个线程上工作吗？
不能在一个线程(.)中拥有属于同一组的多个使用者。这意味着，一般来说，消费者可以共享一个线程，而且如果我们试图从一个应用程序中将同一个组设置为多个使用者，它有时可能无法工作。第二个问题是，为什么当我将num.stream.threads设置为更大的用户数量时，它没有帮助。
浏览 4提问于2020-04-01得票数 1
回答已采纳
具有消耗的KafkaStreams拓扑，并在一些处理步骤之后生成另一个kafka主题的结果，并配置为： num.stream.threads: 10 JConsole说有20个消费者线程，20个生产者线程，20个心跳线程。为什么这样的线程数量是20而不是10？在大量num.stream.threads的情况下，这似乎是一个很大的开销-在生产中，我们已经配置了64个，并且有400多个Java本机线程。
浏览 20提问于2019-03-22得票数 1
回答已采纳
我有一个真正的环境与3 kafka机器集群，这是接收大量数据。对于每个主题，有25个复制因子设置为2的分区。 我的应用程序(基于kafka流的应用程序)从这个kafka集群获取数据，它停机了一个多月。现在，每个分区中都有大量的延迟；总共有90000000个。 我知道以下参数： max.poll.records ; default —> 500fetch.max.bytes ; default —> 52428800
fetch.min.bytes ; default —>
浏览 25提问于2019-05-22得票数 1
transformer(value)).to("other_topic",Produced.with(stringSerde, stringSerde)); More Partitions May Increase End-to-end Latency
那么如何提高吞
浏览 0提问于2019-04-16得票数 0
回答已采纳
我已经检查了文档并浏览了线程模型部分，但是没有找到答案。
浏览 2提问于2020-06-03得票数 1
回答已采纳
如果有一个运行num.stream.threads=4的应用程序实例，则所有4个StreamThreads都会被利用。如果启动了第二个实例(使用num.stream.threads=4)，流任务现在将在这两个实例之间分发。第一个实例上的任务0_1和0_2，第二个实例上的任务0_3和0_4。首先，kafka streams库是否会杀死到目前为止正在运行0_3和0_4的线程？
浏览 1提问于2021-06-23得票数 4
2回答
> 1，那么任务如何分配给准备好的线程和分配的线程(在循环中)？我想(我不确定)有线程池，并且使用某种循环策略将任务分配给线程，但是它可以在运行时完全动态地完成，或者在开始时通过创建筛选/映射到结构来完成一次。是否有可能应用程序会饿死，因为所有线程都会分配给处理器，这很费时。让我们来玩一下场景：num.stream.threads=2、每个主题的no. partitions=4、no. topics=2 (huge_topic和slim_topic) -
浏览 4提问于2017-10-09得票数 1
回答已采纳
num.stream.threads=10 max.poll.record=90
是消费者消费了10个线程的topic中的90条记录，还是消费者中的10*90=900消息。
浏览 1提问于2020-07-02得票数 0
我想知道ProcessorContext.schedule是否是线程安全的，这样我就可以产生新的线程来执行Punctuator回调？另外，如果消费者只使用了1个分区，但我们设置了num.stream.threads=2。这会自动为调度器产生一个新线程吗？
在尝试了一下之后，我发现答案可能是“不”。那么，有什么推荐的方法可以让派生新线程的调度程序线程安全呢？
浏览 13提问于2019-08-02得票数 0
回答已采纳
1回答
我有8个分区的主题，其中应用程序不断发布/发布消息到主题，并在此主题的顶部创建了一个Kstream。到目前为止，我很好地创建流，因为我只启动了一个实例( JVM )，根据文档，流在本地JVM中创建，但我的问题是，如果将代码移到QA或生产中，我将有8个JVM并行运行，因此每个JVM会创建8个流……
现在
浏览 0提问于2019-05-29得票数 0
在我们的Kafka Streams拓扑中，我们有一些标点符号，可能需要很长时间才能运行(几分钟)。 使用如此缓慢的标点符号的后果是什么？它们运行的进程会在标点符号运行时停止处理记录吗？它们会导致再平衡的发生吗？
浏览 17提问于2019-01-17得票数 5
回答已采纳
1回答
根据文档(或者我可能遗漏了什么)，每个分区都有一个任务，意味着不同的处理器实例，每个任务由不同的线程执行。但是当我测试它时，我发现不同的线程可以得到不同的处理器实例。value) {输出：线程id: 88 I
浏览 2提问于2017-11-05得票数 3
回答已采纳
32卡夫卡用户属于同一组，投票间隔与案例1相同，addAll为线程安全列表。
哪个设计会导致一个更快增长的列表，为什么呢？谢谢。
浏览 0提问于2019-09-18得票数 1
回答已采纳
我希望动态地调整num.stream.threads配置，以便在程序运行时控制每个实例的优先级。我想知道还有别的办法吗？
浏览 2提问于2019-01-04得票数 1
回答已采纳
我的理解是创建200个任务来匹配输入主题的分区#。
这个Kafka应用程序运行在C4.XLarge上&这200个任务运行在单个流线程上，这意味着这个流线程应该耗尽所有的CPU内核(8) &内存。我知道Kafka流的并行性/可伸缩性是由流线程数控制的。我可以将num.stream.threads提高到10，但是如果所有这些都运行在单个EC2实例上，它将如何提高性能？它与在单个EC2实例上运行单个流线程上的所有任务有什么不同？
浏览 2提问于2020-08-04得票数 0
回答已采纳
1回答
我有一个使用Apache流的应用程序。对于卡夫卡消费者，同样的consumer.group.id保证在不同的情况下(即不同的机器)不同的应用被视为相同的消费者群体。卡夫卡流中有类似于consumer.group.id的东西吗？(也就是说，当他们拥有same configuration时，他们认为是相同的流)
浏览 0提问于2018-03-12得票数 1
回答已采纳
我有GUI线程，它创建和管理GUI内容。现在，当应用程序空闲时，即所有线程都是空闲的(或者即使只有GUI线程是空闲的)，那么我希望我的QMainWindow继承类的对象发出一个SIGNAL。因此，每当应用程序空闲时，我将静默地创建下一阶段所需的Widgets。因此，我想知道如何使该对象在GUI空闲时发出一个SIGNAL？我的应用程序是多线程的&有多个类，所以不需要只在GUI类中发出SIGNA
浏览 0提问于2013-02-15得票数 8
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号