《中银消费金融面经》专题

我只是在试用这里提到的kafka-storm喷口https://github.com/nathanmarz/storm-contrib/tree/master/storm-kafka，我使用的配置如下所述。 但是，上面的喷子从Kafka主题中获取消息的速度大约是每秒7000条，但我预计每秒大约有50000条消息。我尝试了在spoutConfig中增加提取缓冲区大小的各种选项，但没有看到任何结果。

我正试图按照GitHub的建议设置测试 其中StreamProcessor设置为 -->line从不使用在我看来应该在主题“output”上的消息，因为@StreamProcessor有@Sendto（“output”） 我希望能够测试流处理的消息。

高级使用者 API 似乎一次读取一条消息。 如果消费者想要处理这些消息并提交给其他下游消费者(如Solr或Elastic-Search ),这可能会给他们带来很大的问题，因为他们更喜欢批量接收消息，而不是一次接收一条。 在内存中批处理这些消息也并非易事，因为只有当批处理已经提交时，Kafka中的偏移量也需要同步，否则具有未提交下游消息的崩溃的 kafka 使用者（如在Solr或ES中）将已经更新其

我有一个Kafka主题，并为其附加了1个消费者(主题只有1个分区)。现在对于超时，我使用默认值(心跳:3秒，会话超时:10秒，轮询超时:5分钟)。 根据留档，轮询超时定义消费者必须在其他代理将该消费者从消费者组中删除之前处理消息。现在假设，消费者只需1分钟即可完成处理消息。 现在我有两个问题

我最近开始学习Kafka，最后就问了这些问题。 > 消费者和流的区别是什么？对我来说，如果任何工具/应用程序消费来自Kafka的消息，那么它就是Kafka世界中的消费者。 流与Kafka有何不同？为什么需要它，因为我们可以使用消费者API编写自己的消费者应用程序，并根据需要处理它们，或者将它们从消费者应用程序发送到Spark？ 我做了谷歌对此，但没有得到任何好的答案。抱歉，如果这个问题太琐碎了。

Kafka在2个代理和1个Zookeeper实例中的奇怪问题，都在AWS上。每个代理都位于一个单独的可用性区域(AZ)。孤独的动物园管理员实例与其中一个代理共享AZ。我正试图模拟一种滚动重启的情况，在这种情况下，即使一个代理出现故障，我们也希望数据流向Kafka。 当另一个 AZ 代理被移除时，我能够看到向与 Zookeeper 共享 AZ 的代理平稳过渡。但是，当我删除与 Zookeeper 共

我有一个主题列表（目前是10个），其大小可以在未来增加。我知道我们可以产生多个线程（每个主题）来消耗每个主题，但在我的例子中，如果主题的数量增加，那么消耗主题的线程数量也会增加，这是我不希望的，因为主题不会太频繁地获取数据，所以线程将是理想的。 有没有办法让单个消费者从所有话题中消费？如果是的话，我们怎样才能做到呢？另外，Kafka将如何维护抵消？请建议答案。

有什么不同吗？术语KafkaConsumer和KafkaListener可以互换使用吗？

我在kafka文档中读到：kafka还有一个命令行使用者，它将把消息转储到标准输出。 bin/kafka-console-consumer.sh--zookeeper localhost:2181--topic test--从头开始 我想知道如果我想要使用消息并将它们推送到另一个输出，应该向上面的命令添加哪些选项。kafka-console-consumer没有--help选项，我找不到任何参数，

我正在尝试实现销售消耗品（硬币）的谷歌应用内计费。我用一个非消耗品测试了它，它工作正常。但是我不能让它成为消耗品。每次我测试它，我只能买一次！这是我的代码： 公共类MainActivity扩展了AppCompatActivity{IabHelper mHelper； ### 对不起我的英语，谢谢。

我没有使用分区发布到Kafka主题。ProducerRecord（字符串主题、K键、V值）

我在站点1（3个代理）有两个集群设置cluster-1，在站点2（3个代理）有两个集群设置cluster-2。使用spring kafka（1.3.6）消费者（一台机器）并通过@KafkaListener注释收听消息。我们如何为每个集群（c1和c2）实例化多个KafkaListenerContainerFactory，并同时监听来自这两个集群的数据。 我的侦听器应该同时使用来自这两个集群的消息。

生产者线程与消费者线程使用信号量同步 生产者线程与消费者线程使用信号量同步 源码/* * Copyright (c) 2006-2018, RT-Thread Development Team * * SPDX-License-Identifier: Apache-2.0 * * Change Logs: * Date Author Notes * 2018-08-24 yangjie the f

所谓的生产者消费者模型就是 某个模块（函数）负责生产数据，这些数据由另一个模块来负责处理 一般生产者消费者模型包含三个部分 生产者、缓冲区、消费者 为什么生产者消费者模型要含三个部分？直接生产和消费不行么？ 一个案例说明一切 生产者好比现实生活中的某个人 缓冲区好比现实生活中的邮箱 消费者好比现实生活中的邮递员 如果只有生产者和消费者, 那么相当于只有写信的人和邮递员，那么如果将来过去的邮递员离职

我在使用者组中轮询来自 Kafka 的消息时遇到问题。我的使用者对象分配给给定的分区 之后，消费者向该分区分配： 之后，我可以计算分区内的消息 和 ..... 在我的主题中有超过30000条消息。问题是我只收到一条消息。 具有< code > max _ poll _ records = 200 < code > AUTO _ OFFSET _ RESET 的消费者配置是最早的 这是我的函数，我正