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

Ribbon介绍 Ribbon是Netflix发布的开源项目，主要功能是提供客户端的软件负载均衡算法，将Netflix的中间层服务连接在一起。Ribbon客户端组件提供一系列完善的配置项如连接超时，重试等。简单的说，就是在配置文件中列出Load Balancer后面所有的机器，Ribbon会自动的帮助你基于某种规则（如简单轮询，随机连接等）去连接这些机器。我们也很容易使用Ribbon实现自定义的负

我们希望获得Kafka消费群体指标（例如，节流和字节率）。 我们已经使用以下工具完成了此操作： Kafka消费者Java应用程序的JMX Mbean CLI实用程序： bin/kafka-consumer-groups.sh--描述--组group_name--bootstrap-serverlocalhost： port . 问题：这可以通过使用一些Java库以编程方式完成吗？ 到目前为止，我们

有一个基本示例，它对1个消费者起作用。它接收消息。但是添加一个额外的消费者将被忽略。 consumer2的“22”事件从未引发问题。如果我使用命令行工具检查该主题，则该主题的数据存在

我观察到，运动流中存在一些记录，但KCL消费者应用程序尚未收到这些记录。发生这种情况的原因是什么？之前和之后的记录都很好。 所有异常都在我的应用程序中消耗，KCL不会收到。所以http://docs.aws.amazon.com/streams/latest/dev/troubleshooting-consumers.html#w1ab1c11c11c15b9的情况也没有发生。 一些细节：打开分片

我有一个Spring-boot应用程序，可以听Kafka。为了避免重复处理，我尝试手动提交。为此，我在阅读主题后异步提交了一条消息。但是我被困在如何实现消费者幂等，这样记录就不会被处理两次。

我在kafka消费者文档中看到了这个注释-

我的主要问题是：在JPA实体类内的方法上，除了@Consumed注释之外，还有其他选择吗？ 我问这个问题是因为我真的想把我的JPA模型（例如我的所有实体）具体化，以便能够在使用相同数据库的其他项目之间共享。此外，我不想在我的子项目中出现一些骆驼依赖，这意味着要删除@Consumed注释。我基本上有这样一条路线： 我尝试了不同的解决方案： 在我的camel项目中，使用@Consumed方法扩展子模块

我正在使用Spring Kafka消费者。我已将并发设置为10，并创建了5个消费者（用于5个主题）。所以有50个Spring Kafka消费者线程。 Kafka消费者可以使用的最大线程数是多少？如何增加此线程池的大小？我查阅了spring文档，但没有发现任何相关内容。

我需要使用consume process Product模式来处理Kafka消息，并已使用Kafka事务管理器配置了Spring Kafka侦听器容器，还设置了事务id前缀以启用Kafka事务。我正在使用批处理的ack模式，并试图了解在这种模式下，在事务中何时提交偏移量。文档似乎表明，一旦使用了轮询中的所有记录，ack模式批提交偏移量——在事务上下文中也是这样吗，即每个轮询1个事务？ 或者，在使用

我想在远程位置检查Kafka消费者的连接。 可以确定是否将使用者分配给分区。 在远程位置，我可以从Kafka代理获得有关该主题的详细信息。 但是消费者能否保证消费者能够收到消费者与主题分区匹配的消息？

我正在建立一个新的Kafka集群，为了测试目的，我创建了一个有1个分区和3个副本的主题。 有什么想法哪种配置或其他东西可以帮助我消费更多的数据吗？？ 提前致谢

我有一个从JMS队列读取项目并将其写入数据库的路径。 我已经阅读了关于ApacheCamelJMS组件的文档，但我没有得到我的问题的确切和明确的答案，即“如果路由中出现异常，JMS消费者是否会重新插入项目或解锁JMS队列中的消息？”。 谢谢 阿里

我是Guice的新手，正在为以下用例寻求帮助: 我开发了一个软件包（PCKG），其中该软件包的入门级依赖于其他类，例如： 在我的绑定模块中，我正在做： 注意我没有为A提供绑定信息，因为我想通过它的消费者类来提供它的绑定。(设计就是这样，所以我的要求是继续讨论主要问题，而不是设计)。 现在，我的消费者阶层正在做这样的事情: 同样在我的消费者包装中： Q1。我在消费者类中做的绑定正确吗？我很困惑，因为

关于KafkaConsumer(>=0.9)，我在尝试实现满足自己需求的解决方案时遇到了一些严重的问题。 假设我有一个函数，它只能从一个Kafka主题中读取n条消息。 例如:-->获取主题中的下5条kafka消息。 所以，我有一个类似这样的循环。用实际正确的参数编辑。在本例中，使用者的max参数设置为1，因此实际循环只循环一次。不同的消费者（他们中的一些人迭代了许多消息）共享一个抽象的父亲（这一个

我对骆驼生产商有很好的了解，但我不能对各种骆驼消费者保持清醒的头脑。特别是事件驱动消费者和轮询消费者，camel如何知道为这些消费者调用回调？ 消费者的一般流量是多少？