broker相关内容

如何使用Java在Mosquito中添加新的已验证用户

我配置了我的本地Mosquito，以便它在端口8883上只接受使用TLS协议进行身份验证的用户。 目前，我使用密码在"；passwd"；文件中创建了一些用户，我链接了do matterto.conf文件，以便它可以识别通过身份验证的用户。 我是否可以用Java编写一些代码，允许我修改运行时的"；passwd"；文件，以便我可以自动添加新用户的密码，以便他 ..
发布时间：2022-03-28 16:54:11 Java开发

Kafka 集群 - 生产者

我有几个关于 Kafka 的问题.如果有人可以通过回复其中之一来帮助我，我将不胜感激. 先谢谢你:) Q1) 我知道分区在 Kafka Broker 之间分开.但分裂是基于什么?.例如，如果我有 3 个代理和 6 个分区，如何确保每个代理将有 2 个分区?Kafka 目前是如何进行这种拆分的? Q2) 当生产者发送一条新消息时，消息的默认格式是什么?Avro 格式 ?例如，如何将 ..
发布时间：2021-11-15 00:06:34 其他开发

Zookeeper 是 Kafka 的必备品吗?

在 Kafka 中，我只想使用单个代理、单个主题和具有一个生产者和多个消费者的单个分区(每个消费者从代理获取自己的数据副本).鉴于此，我不想要使用 Zookeeper 的开销；我不能只使用经纪人吗?为什么必须要有动物园管理员? 解决方案 是的，运行 Kafka 需要 Zookeeper.来自 Kafka 入门文档: 第 2 步:启动服务器 Kafka 使用zookeeper，所 ..
发布时间：2021-11-14 23:54:53 其他开发

Kafka 集群 - 生产者

我有几个关于 Kafka 的问题.如果有人可以通过回复其中之一来帮助我，我将不胜感激. 先谢谢你:) Q1) 我知道分区在 Kafka Broker 之间分开.但分裂是基于什么?.例如，如果我有 3 个代理和 6 个分区，如何确保每个代理将有 2 个分区?Kafka 目前是如何进行这种拆分的? Q2) 当生产者发送一条新消息时，消息的默认格式是什么?Avro 格式 ?例如，如何将 ..
发布时间：2021-11-12 03:05:06 其他开发

Kafka:动态更新 jaas 配置

我已经使用 sasl.jaas.config 属性为 kafka 设置了 jaas 配置.我想更新这个配置并动态添加用户. 根据此文档 - http://kafka.apache.org/11/documentation.html#dynamicbrokerconfigs，我们可以通过使用 bin/kafka-configs.sh 来做到这一点. 上述文档有配置列，如下所示 - ..
发布时间：2021-11-12 02:51:42 其他开发

在 kafka 中处理经纪人

我在异步模式下使用 kafka 生产者，但是当所有代理都关闭时，它的行为就像同步一样，它会一直等到 metadata.fetch.timeout.ms 过期，这对我来说是 60 秒.我的第一个问题，这是正常行为还是我做错了什么? 因为我的逻辑中的事务应该在最多 100 毫秒内完成，所以这个超时值对我来说是一个非常大的延迟.也许将 metadata.fetch.timeout.ms 设置为 1 ..
发布时间：2021-11-12 02:38:28 其他开发

Zookeeper 是 Kafka 的必备品吗?

在 Kafka 中，我只想使用单个代理、单个主题和具有一个生产者和多个消费者的单个分区(每个消费者都从代理获取自己的数据副本).鉴于此，我不想要使用 Zookeeper 的开销；我不能只使用经纪人吗?为什么必须要有动物园管理员? 解决方案 是的，运行 Kafka 需要 Zookeeper.来自 Kafka 入门文档: 第 2 步:启动服务器 Kafka 使用zookeeper， ..
发布时间：2021-11-12 01:42:14 其他开发

为什么Celery worker给出"OSError:套接字已关闭"?

我的与RabbitMQ一起工作的芹菜工人在工作了几分钟后，一直给我一个套接字错误-见下文.我想知道问题的主要原因是什么?我以为可能是防火墙.但是，禁用防火墙并不能解决问题.我正在Windows 10计算机上工作. C:\ Users \ user_ \ Desktop \ Aida> celery -A任务工作程序-l info -P eventlet-------------- celery ..
发布时间：2021-04-21 19:58:36 其他开发

Kafka Cluster-生产者

我对卡夫卡有几个问题。如果有人可以通过回答其中一个来帮助我，我将非常感激。 在此先感谢您：） Q1）我知道分区是在Kafka Broker中拆分的。但是拆分基于什么？例如，如果我有3个代理和6个分区，那么如何确保每个代理将有2个分区？ Qf）当前生产者发送新消息时，消息的默认格式是什么？该消息在Kafka中是如何产生的？ Q2） Avro格式？如何将这种默认格式更改为更适合的另一 ..
发布时间：2020-06-07 18:41:46 其他开发

Kafka：动态更新jaas配置

我已经使用 sasl.jaas.config 属性为kafka设置了jaas配置。我想更新此配置并动态添加用户。 根据此文档- http://kafka.apache.org/11/documentation.html#dynamicbrokerconfigs ，我们可以使用 bin / kafka-configs来实现.sh 。 上面的文档具有“配置”列，内容如下- 我尝试使用 ..
发布时间：2020-06-07 18:41:43 其他开发

RabbitMQ 3.1.3和缺少的时间戳头

是否可以配置代理以在消息中缺少时间戳头时插入它？因此，如果发布客户端未添加时间戳标头，则代理是否可以将其插入与交易所收到消息的那一刻匹配的时间戳值？我应该在哪里寻找该配置？还是一个坏主意？ 解决方案 要回答您的问题，没有办法配置代理插入时间戳。 AMQP规范中的任何内容都不需要消息知道消息何时到达代理，并且请记住，在代理端手动插入时间戳仅表示代理何时接收消息，而不是消息何时发布。 如 ..
发布时间：2020-06-07 18:41:40 其他开发

MessageQueue的契约：如果有MessageQueues，则示例提供程序测试

我已通过参考pact仓库中给出的示例示例为MessageProvider编写了示例Pact测试。以下是消费者测试，该测试正在为Provider期望的消息生成PACT json文件。 对于API，要验证PACT，我可以使用“ pact-jvm-provider-maven”插件来执行此操作。在这种情况下，将根据提供商的 actual 托管API服务对PACT进行验证。 我的问题是，在Me ..
发布时间：2020-06-07 18:41:34 其他开发

WebSphere Message Broker-如何发送PCF消息

我们需要从MB流发出一些MQ命令。 的方法是发送PCF命令，但是我不知道如何创建它。 任何指针？ Sebastian。 解决方案 要通过PCF消息向MQ队列管理器发出命令，您可以查看/中的示例。 * nix上或您安装过MQ的任何地方的opt / mqm / samp / pcf / samples。 （在Windows上，尝试“ C：\程序文件（x86）\IBM\WebSphere ..
发布时间：2020-06-07 18:41:32 其他开发

Zookeeper是Kafka的必需品吗？

在Kafka中，我只想使用一个代理，单个主题和一个分区，该分区具有一个生产者和多个消费者（每个消费者都从代理获取自己的数据副本）。鉴于此，我不需要使用Zookeeper的开销；我不仅可以只使用经纪人吗？为什么Zookeeper必须？ 解决方案 是的，运行Kafka需要Zookeeper。从Kafka入门文档中： 步骤2：启动服务器 Kafka使用zookeeper，因此如果您没 ..
发布时间：2020-06-07 18:41:29 其他开发

Mosquitto 1.4.2 Websocket支持

我正在尝试利用Mosquittos的最新更新来支持代理中的Websocket.我正在运行Mosquitto v1.4.2，并将以下行添加到mosquitto配置文件(mosquitto.conf): listener 10001 127.0.0.1 protocol websockets listener 1883 protocol mqtt 当我尝试使用新配置启动代理时，我得到以下信 ..
发布时间：2020-05-12 18:46:46 其他开发

在RabbitMQ中，哪个更昂贵，每个交换有多个队列，还是每个交换有多个交换而每个队列较少?

因此，我们决定在迁移到微服务体系结构中将RabbitMQ用作消息/事件总线，但是对于什么是最好的排队方法，我们找不到确切的答案，我们有两种选择配合: 一个主要的交换将是扇出交换，它将依次将消息散发到主队列以进行日志记录和其他用途；另一个子交换将是主题交换并将消息路由到每个所需的队列使用消息路由密钥.我们期望子交换后面的队列数量可以达到一定数量.可以通过以下图表对此进行说明: 一个主交换，将 ..
发布时间：2020-05-09 01:16:04 其他开发

在卡夫卡处理经纪人

我正在异步模式下使用kafka生产者，但是当所有代理都关闭时，它的行为就像同步，并且它等待直到meta.fetch.timeout.ms到期，这对我来说是60秒.我的第一个问题是这是正常现象还是我做错了什么? 由于我的逻辑中的事务最多应在100毫秒内完成，因此该超时值对我来说确实是一个很大的延迟.也许将metadata.fetch.timeout.ms设置为10 ms可能会解决我的问题，但是 ..
发布时间：2020-04-25 08:38:15 其他开发

盈透证券的Java API得到所有的职位吗？

我通过IB的Java API去了，看不到任何函数获取在我的投资组合目前所有的股票/期权头寸。我所试图做的是：获得我的投资组合目前所有的/主动仓位（仓位可能会或可能不会从API发送），然后循环通过列表，关闭符合我的标准之一。有没有办法做到这一点？ 感谢， 解决方案 使用 reqAccountUpdates（真）方法开始接收有关帐户的事件。然后，你通过 updatePortfolio（）事件 ..
发布时间：2016-05-23 22:11:49 Java开发