《中邮消费金融有限公司》专题

我有一个主应用程序将消息发送到SQS队列，希望4个消费者应用程序使用相同的消息，并按自己的意愿进行处理 我不确定用于此目的的队列体系结构。 我看到标准SQS、SQS FIFO、（SQS SNSTopic）的选项 对于我想要的功能，似乎（SQS SNS主题）或Kenesis将是一条可行的道路。 但是我也有一个关于标准SQS的问题 我想我是混淆之间的所有选项和压倒了所有的信息可用的队列但仍然感到困惑哪

我在骡子流中使用CXF JAX-WS来访问服务。 我能够成功访问它。 是否有任何方法可以在发送之前看到正在发送到服务的消息？

这是我的消费者： 所以当运行我的制作人时，它最终会出错。任何人都知道这意味着什么，如果这可能是错的。

我正在使用Kafka python版本2.0.2来生成和消费消息：我的生产者： 我的消费者: 当我运行消费者时，它运行得很好。但是当我在它完成所有消息之前停止它时，它不会从我停止的地方继续，如果我的程序崩溃或笔记本电脑没电了怎么办？我如何解决每个问题？我希望消费者继续阅读未阅读的消息？

我第一次在kafka中使用Node,使用Kafka-Node。使用消息需要调用外部API，这甚至可能需要一秒钟的时间来响应。我希望克服我的消费者的突然失败，这样，如果一个消费者失败了，另一个将替换它的消费者将收到相同的消息，即它的工作没有完成。 我正在使用Kafka0.10并尝试使用ConsumerGroup。 我想到了在options中设置，并且只在消息的工作完成后提交消息（就像我以前对一些Ja

按照此处提到的解决方案，kafka-mire-maker-fasting-to-复制-消费者-偏移-主题。我能够跨DC1（Live Kafka集群）和DC2（Backup Kafka集群）集群启动镜像制作器而没有任何错误。 看起来它还能够从DC1集群跨DC2集群同步主题。 问题 如果我关闭 DC1 的使用者并将同一使用者（同一group_id）指向 DC2，即使镜像制造商能够同步本主题和分区的偏移

我是一个新的Kafka和使用Apache kafka消费者读取消息从生产者。但当我停下来开始一段时间。之间产生的所有消息都将丢失。如何处理这种情况。我正在使用这些属性“auto.offset.reset”、“latest”和“enable.auto.commit”、“false”。 这是我正在使用的代码。任何帮助都是感激的。

我正在尝试使用以下命令公开docker注册表： 来源:https://docs . open shift . com/container-platform/3.3/install _ config/registry/securing _ and _ exposure _ registry . html # access-unsecured-registry-by-exposure-route 但是

注意：这将只显示有关使用Java消费者API的消费者（非基于ZooKeeper的消费者）的信息。 此工具还适用于基于ZooKeeper的使用者： bin/kafka-consumer-groups.sh--zookeeper localhost：2181--description--group my-group null PS：这似乎没有出现在2.5文档中

使用redis stream，用消费组，消费消息ack后仍然存在，看了下占用内存数量随着消息增长逐渐增加，ack后内存也不缩小，那这样长时间运行，消息占用的空间回越来越大，redis会回收内存或定期删除ack的消息么？这种情况如何处理？

我很难在Kafka主题的消费者中找到处理异常的简单模式。场景如下：在消费者中，我调用一个外部服务。如果服务不可用，我想重试几次，然后停止消费。 最简单的模式似乎是一种处理它的阻塞同步方式，在Java中如下所示： 但是，我觉得必须有一种更简单的方法（不使用第三方库），并且避免阻塞线程。 这似乎是我们想要的一种常见的东西，但我找不到一个简单的例子来说明这种模式。

我有一个（Posix）服务器，它充当许多客户端到另一个上游服务器的代理。消息通常从上游服务器向下流动，然后与之匹配，并被推出到对该流量感兴趣的客户端的某个子集（维护来自上游服务器的FIFO顺序）。目前，这个代理服务器是使用事件循环的单线程（例如-select、epoll等），但现在我想将它变成多线程，这样代理就可以更充分地利用整个机器并实现更高的吞吐量。 我的高级设计是拥有一个由N个工作线程组成的

使用指南 - 疑难问题 - 数据缺失或无数据问题 - 为什么推广报告只有消费点击而无浏览数据？ 推广报告中的消费点击数据是账户粒度的，而统计报告是站点粒度的。 因此如果您有多个站点，需要将所有站点的浏览效果数据相加之后，与推广的消费点击数据作比较。 请检查您当前所选的站点是否是正在投放的推广站点。如果不是，请切换站点查看效果数据。

我是HashiCorp Vault的新手，到目前为止，我已经一一完成了教程，我已经清除了安装Vault和设置服务器。我什至学会了创造一个秘密，没有问题。我在秘密引擎中面临问题..当我输入命令“保管库机密启用 -path=kv kv”时，我收到一条错误消息，说“启用时出错：发出 API 请求时出错。 网址：邮政http://127.0.0.1:8200/v1/sys/mounts/kv代码：403。

先简要做自我介绍，之后面试官问一些变成方面的简单问题、关于家庭方面的问题、户口等。 两个技术主管两个hr，两个技术主管会轮流问问题，主要针对自己做过的项目，C语言和一些嵌入式外设。 为什么来交大思诺？ 技术问题的整理： 1、c语言程序方面的一些简单的问题 2、stm32如何进入中断？ 3、exter “C”的作用？ 4、数据如何在单片机上计算？从哪里取出，放到哪里？ 5、static的作用，面试官