在生产者中，何时发生QueueFullException？
答：每当Kafka生产者试图以代理的身份在当时无法处理的速度发送消息时，通常都会发生QueueFullException。但是，为了协作处理增加的负载，用户需要添加足够的代理，因为生产者不会阻止。
-
如果我只在生产者端发送一条记录并等待，生产者何时将记录发送给经纪人？在Kafka文档中，我找到了名为“linger.ms”的配置，它说： 一旦我们得到 根据以上文件，我有两个问题。 > 如果生产者收到的数据达到batch.size，它会立即触发发送一个只包含一个批次的请求给代理？但是正如我们所知，一个请求可以包含许多批次，那么它是如何发生的呢？ 这是否意味着即使是收到的数据也不足以批量处理。大小，
-
前期回顾 其中channel.finishConnect()中完成建立连接，调用了 sender的run（），继续分析 其中步骤五和步骤七： 会把发往同个broker上面partition的数据组合成为一个请求，然后统一一次发送过去，这样子就减少了网络请求。调用send（） 调用selector的send（） 调用kafkachannel的setsend() 开始发送数据 sender里面的pol
-
我是新的Flink流处理，并需要一些帮助与FlinkKafka生产者，因为不能找到很多相关的搜索后一段时间。我目前正在阅读一个Kafka主题的流，然后在执行一些计算后，我想把这个写到新的Kafka中的一个分离主题。但我面临的问题是，我无法发送Kafka主题的关键。我使用的是Flink Kafka连接器，它给了我FlinkKafkaConsumer和flinkkafkaProducer。更详细的查看
-
最近，我们与Kafka消费者和生产商之间出现了一些性能问题。我们在scala中使用Kafka Java API。打开和关闭消费者和生产者对象的良好做法是什么？我认为这是一个非常开放的问题，正确的答案总是，但我正在尝试对此进行推理。 消费者可以长时间运行连接并保持开放吗？ 当我们完成信息生成时，生产者是否应该关闭？
-
我有一个消费者作为生产者消费者模式的一部分： 简化： 如果我移除 通过将线程设置为睡眠，CPU使用率攀升到极高的水平（13%），而不是0%。 此外，如果我实例化该类的多个实例，则每个实例的CPU使用率都会以13%的增量攀升。 大约每分钟（可能每30秒）都会向BlockingCollection添加一个新的LogItem，并将适用的消息写入文件。 有没有可能线程以某种方式阻止了其他线程的运行，而系统
-
我有一个生产者/消费者模式，如下所示 固定数量的生成器线程，每个线程写入它们自己的BlockingQueue，通过执行器调用 单个使用者线程，读取生产者线程 每个生产者都在运行一个数据库查询，并将结果写入其队列。消费者轮询所有生产者队列。目前，如果出现数据库错误，生产者线程就会死掉，然后消费者就会永远停留在产品队列中等待更多的结果。 我应该如何构造它来正确处理catch错误？