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

我有一个支持amqp和OpenWire的activeMQ代理。openwire(tcp，端口61616)的生产者有可能生产到一个队列，该队列的消费者使用amqp协议吗？ 或者我只限于相同的协议消费者和生产者？

我将python（aioredis）与redis streams一起使用。 我有一个一个生产者-多个（分组）消费者的场景，并希望确保消费者以有序的方式处理发送到流的（批量）消息，这意味着：当第一条消息完成时，处理流中的下一条消息，依此类推。这也意味着消费者组中的消费者在某一时间正在处理，而其他消费者将等待。 我还希望依赖于第二、第三等消费群体中的有序处理——所有这些都依赖于发送到一个流的相同消息。

我试图找到一种在以下场景中使用ThreadPoolExecutor的方法： 我有一个单独的线程在线程池中生成和提交任务 为了提供更多的上下文，我目前只需一次提交所有任务，并取消ExecutorService返回的所有未来。在最长生成时间到期后提交。我忽略所有产生的取消异常，因为它们是预期的。问题是未来的行为。cancel（false）很奇怪，不适合我的用例： 它可以防止任何未启动的任务运行（良好）

我正在研究一个示例，其中JMS队列托管在JBoss EAP 6实例上（一个用于请求，另一个用于响应）。我还有一个在Weblogic托管服务器上运行的应用程序。 我想设置一种机制，允许运行在Weblogic上的应用程序能够使用添加到JBoss上的请求队列上的消息。此外，应用程序应该能够将消息发布到请求队列（也托管在JBoss上） 我在Oracle文档中读到了关于外国JNDI提供程序的信息，我找到的大

本文向大家介绍使用信号量的生产者消费者问题，包括了使用信号量的生产者消费者问题的使用技巧和注意事项，需要的朋友参考一下 生产者消费者问题是同步问题。有一个固定大小的缓冲区，生产者生产商品并将其输入缓冲区。消费者从缓冲区中删除项目并消费它们。 当消费者从缓冲区中消费商品时，生产者不应将商品生产到缓冲区中，反之亦然。因此，缓冲区只能一次由生产者或使用者访问。 生产者消费者问题可以使用信号量解决。生产者

我正在数据库中为主题外部化kafka消费者元数据，包括消费者组和组中消费者的数量。 Consumer\u info表具有 主题名称，消费者组名称，组中的消费者数量消费者类名称 在app server启动时，我正在读取表并根据表中设置的数字创建使用者（线程）。如果使用者组计数设置为3，我将创建3个使用者线程。这基于给定主题的分区数 现在，如果我需要横向扩展，我如何将属于同一组的消费者分布在多个应用服

Kinesis流用于从调用应用程序馈送消息，我们从Kinesis流中获取消息并进行处理。KPL（本地）用于将数据生成（馈送）到Kinesis中，KCL（@AWS EC2）用于消费者端KPL正在以良好的速度生成消息，但由于流转时长问题1，消费者需要更多时间

假设我有一个Kafka主题，大约有10个分区，我知道每个消费群体应该有10个消费者在任何给定的时间阅读该主题，以实现最大的平行性。 然而，我想知道，对于一个主题在任何给定时间点可以处理的消费者群体的数量，是否也有任何直接规则。（我最近在一次采访中被问及这一点）。据我所知，这取决于代理的配置，以便在任何给定的时间点可以处理多少个连接。 然而，我只是想知道在给定的时间点可以扩展多少个最大消费群体（每个

问题内容： 我需要为后端使用老式的RPC /编码WSDL Web服务。最初，我尝试为此使用Apache CXF和JAX-WS，但是JAX-WS 工具不使用rpc /嵌入式WSDL。 [错误] JAXWS 2.0不支持rpc /已编码的wsdls。 我也对使用JAX-RPC进行这项工作有疑问，因为它已经过时了。Axis 1.4已使用5年。 目前，我看到以下三个选项： 一个示例，使用JAX-WS 发送

我正在读这篇： 自动提交提交偏移量最简单的方法是允许消费者为您执行。如果您配置启用。汽车commit=true，则每五秒钟消费者将提交客户端从poll（）收到的最大偏移量。五秒钟的间隔是默认值，由设置“自动”控制。犯罪间隔ms.与消费者中的其他所有内容一样，自动提交由轮询循环驱动。无论何时进行轮询，使用者都会检查是否到了提交的时间，如果是，它将提交上次轮询中返回的偏移量。 也许问题是我的英语不好，

我有一个服务，它从不同的Spring云流通道（绑定到EventHub/Kafka主题）生成和使用消息。有几种设置类似的服务。 配置如下所示 生产者/发布者代码如下所示 类似地，我还有多个其他发布者发布到不同的活动中心/主题。请注意，每个已发布的消息都有一个租户id标头。这是我的多租户应用程序特定于跟踪租户上下文的内容。还请注意，在发送消息时，我正在获取要发布到的频道。 我的消费者代码如下所示 同样

我没有使用Spring Kafka模块来生成和使用消息。相反，我在生产者和消费者实现中使用Apache客户端库。由于我没有使用Spring Kafka，因此Spring Slueth自动配置不适用于生成跟踪。我已经提到https://docs.spring.io/spring-cloud-sleuth/docs/current-SNAPSHOT/reference/html/integration

我们有一个基于spring boot的事务性Kafka制作人！使用的版本如下 spring-boot-starter-父-2.3.0。释放 spring-kafka-2.5.0。释放 我们的kafka（集群）版本是2.1. x！ 作为生产者，我们启用了幂等性，定义了事务id前缀，并在事务中执行kafka模板调用。我们还有一个将隔离级别设置为只读的使用者！ 现在我们遇到了一个行为，不知道如何推断，

我看到，尽管kafka主题有大量（数百万）消息排队，vert. x消费者只获取500条消息（默认获取量），然后将其传递给处理程序。但是在消息被处理和提交后，消费者只是停下来等待大约35秒，直到它获取另一批消息。 我希望消费者会继续获取，直到它设法赶上分区，然后暂停。我如何让它这样做？ 使用以下代码设置消费者: 为消费者提供以下配置： 我使用的是vert.x 3.9.2，Kafka是2.4.1

我正在阅读Kafka的文档，注意到下面一行： 但是，请注意，使用者组中的使用者实例不能多于分区。 嗯。如何自动缩放？ 这是Kafka的限制但是...如果我理解这是如何工作的，那么两个用户组都将从一个分区（例如msg.hi）中提取，并使用它们自己的偏移量，因此两个用户组都不知道另一个分区--这意味着消息可能会被传递两次！ 我怎样才能达到我在兔子设计中所拥有的Kafka的能力，并且仍然保持行为的“队列