《均衡》专题

刚刚浏览了这些文档： < Li > http://ActiveMQ . Apache . org/failover-transport-reference . html 那么，是否有可能配置消费者和生产者应用程序来连接和平衡多个代理实例之间的负载(以循环或类似的方式)？

我设置了两个MariaDB 10.0 Galera集群节点，在192.168.2.51和192.168.2.52两个专用IP上运行。我即将尝试使用MariaDB网站提供的MariaDB的JDBC客户端（org.mariadb.JDBC.driver）连接到集群。 它可以使用常规url：“jdbc：mariadb：//192.168.2.51:3306,192.168.2.52:3306/dbnam

我的Kafka版本是。集群中有两个代理，4个主题，每个主题有4个分区。 当我跑的时候 对于所有主题/分区，我认为Broker1是领导者。 如何平衡领导的负载？ 例如，对于主题1和主题2，代理1作为领导者，而对于主题3和主题4，代理2作为领导者。

我正在尝试为我的java服务器实现grpc客户端负载平衡。一台服务器运行在端口6565上，另一台服务器运行在端口7575上。两台服务器的代码是相同的，但端口除外。 现在我想为这些服务器实现客户端负载平衡。 我的ServiceRegistry类如下- 我的< code>TempNameResolver类如下所示

我正在尝试使用前端NGINX 1.6.2负载平衡器来平衡API Manager 1.9.0。我有两台服务器： 服务器A（xxx.xxx.xxx.xx1和xxx.xxx.xxx.x11）-公共和私有IP服务器B（xxx.xxx.xxx.xx2和xxx.xxx.xxx.x22）-公共和私有IP API Manager 1.9.0和所有四个组件都在服务器B上安装和启动。 我在服务器A上安装了NGINX，

我知道在你的流中的任何时间点都可能发生再平衡。当它发生时，由于没有提交给定偏移量的最新偏移量，可能会发生事件的重新处理。 Kafka流是否允许在重新平衡发生之前完成任何飞行中处理？我的意思是，你的应用程序正在消耗一个记录（在你的过程方法内部），发生一个再平衡事件。该处理是否立即中止或允许处理方法完成？ 一个具体的例子是 最后一次计算是否会在状态存储中结束并转发到接收器主题？因此，这意味着当重新平衡

我见过一些APM，它只测量运行在WAS上的网络应用程序。 Elastic APM能否衡量纯Java应用程序等其他应用程序的性能？ 如果没有，我可以使用吗https://www.elastic.co/guide/en/apm/agent/java/1.x/public-api.html（公共API），以便它可以测量非web应用程序的性能？ 我将感谢你的建议。干杯

我正在看Spring靴/云和Netflix固件（尤里卡，丝带）。我正在研究这个例子： https://spring.io/blog/2015/07/14/microservices-with-spring基本上是关于一些使用Eureka服务注册表的小型Spring Boot微服务。 我现在想启动同一个服务的几个实例（在这个例子中是Account tService，在不同的端口上）。我读到的一切（上

我目前正在为我的实习做一个微服务应用程序，使用Consul进行服务发现，使用feign clients进行服务间的通信。当我们开始使用微服务构建现有项目时，我们将Spring boot升级到了2.4.3 默认情况下，菲恩使用功能区进行负载平衡，但领事已经对传入请求进行了负载平衡。 我们使用spring.cloud.consul.loadbalancer.ribbon.enable禁用了功能区：在我

我正在使用kafka 0.9.0.1代理和0.9.0.1消费者客户端。我的使用者实例正在使用处理时间小于1秒的记录。和其他主要配置 一小时一两次。每天消耗约60亿次事件。似乎偏移量只存储在主题“__consumer_offsets”的一个分区中。它还会增加特定代理的负载。 有人知道这些问题吗？

今天，在我的Spring Boot和单实例Kafka应用程序中，我遇到了以下问题： CommitFailedException：无法完成提交，因为组已经重新平衡并将分区分配给了另一个成员。这意味着对poll（）的后续调用之间的时间比配置的max.poll.interval.ms长，这通常意味着poll循环花费了太多时间处理消息。您可以通过增加会话超时，或者通过使用max.poll.records减

环境:Hadoop2.75.+Flink1.4+Kafka0.10 我已经建立了一个实时数据处理项目。我使用Flink表源API(Kafka010JsonTableSource）作为表源。从kafka获取数据，然后执行一个SQL，最后输出到一个kafka主题。这是一个清晰的流程，但是我在Flink集群上执行时遇到了异常，下面是我的主要代码： 我已经启用了检查点。第一次在flink上执行时，我只是遵

有人能帮忙吗？原因和解决方法是什么？ 此外，当我的1个kafka代理关闭时，我的kafka流应用程序没有连接到其他代理？我已经设置了

我想使用Feign客户机，并按服务名称在中提供URL。 我使用Spring Boot，并且依赖于Spring Cloud： 我知道如何对属性进行硬编码以从属性读取URL： : 这是一个更好的，但我想脱钩的财产名称与虚假客户端。我只想使用。 这个解决方案似乎更好，因为代码中的Feign客户机只包含（没有URL或URL的耦合属性名称）。这正是我想要的。 但在日志中，我看到Spring/Ribbon为我

我面临的一个问题是KeyedStream在workers上是纯粹并行的，因为键的数量接近并行度 我的输入记录在0-N的范围内。当我使用keyBy时，有些工人处理零个键，有些则不止一个。这是因为在中对Key.HasCode使用murmurHash并选择通道。 我知道partitionCustom可以处理这种情况，但partitionCustom只返回数据流，而不是KeyStream。 那么我能做什么