Skip To Main Content
String groupId on Muck Rack

String groupId

As seen in: CSDN
Is this you? As a journalist, you can create a free Muck Rack account to customize your profile, list your contact preferences, and upload a portfolio of your best work. Claim your profile
Back to String groupId’s profile

Articles by String groupId

SpringBoot+WebSocket 消息推送 校验 心跳机制 PING-PONG 用户分组等

|
By String groupId, string userId
| CSDN
WebSocket PING-PONG心跳机制，只需要服务端发送PING，客户端会自动回应PONG，本文中使用了两个@OnMassage注解一个用于接收Text消息，一个用于接收PONG响应消息，此外还有二进制格式（InputStream ，byte[],ByteBuffer 等）。 说明： 记录一下，自己使用的WebSocket方式。 性能可能不是最优，也有可能有其他隐患。 （作者逻辑可能也点问题，有大佬发现问题还请不用口下留情！） 还有Lombok等自行导入 <!-- websocket --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-websocket</artifactId> </dependency> @Configuration public class WebSocketConfig { /** * ServerEndpointExporter类的作用是，会扫描所有的服务器端点， * 把带有@ServerEndpoint...
Open in Who Shared Issue with article?

使用javaApi监控 kafka 集群的环境下消费组的积压信息

|
By String groupId, kafka.api.Offset Request.Latest Time, long whichTime, kafka.api.Offset Request.Current Version
| CSDN
需求：提供一个能够监控 kafka 集群的环境下消费组的积压信息。当某个消费组积压的信息超过设定的阈值的时候，程序主动告警提醒。 难点： 集群环境，有多个机器。 每个机器上存在多个主题，多个消费组。 使用javaapi查询 思路： 1。先获取集群环境下某台机子下的所有主题 2。查询该主题下绑定的消费组id 3。查询该主题下具体消费组的信息 具体实现 1。环境准备，导入客户端和kafkaApi <!-- 解决： java.lang.NoSuchMethodError: org.apache.kafka.common.network.NetworkSend.<init>(Ljava/lang/String;[Ljava/nio/ByteBuffer;)V --> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>0.11.0.1</version> <exclusions> <exclusion>...
Open in Who Shared Issue with article?

Nacos2.0.3版本线上bug导致整个集群挂掉从而导致业务系统挂掉的解决办法_nacos集群节点挂了_大飞哥～BigFei的博客-CSDN博客

|
By String groupId
| CSDN
nacos官网： https://nacos.io/zh-cn/docs/what-is-nacos.html 问题nacos版本：2.0.3 https://github.com/alibaba/nacos/issues/5343 ​ 原因：由于之前使用的nacos版本是1.4.x，会出k8s中的服务启动后挂掉然后又被拉起又挂掉这种奇葩的问题，后面领导升级到2.0.3之后就出了好几次线上的问题，都是用于部署在k8s中的nacos集群的节点重启之后导致pod的ip改变了，nacos2.x的JRaft选主失败了，导致nacos脑裂成多个个集群，集群数据不同步，最后应用服务发现不了服务，业务系统就挂了一上午或者一下午，临时的解决办法就是重新启动nacos集群和k8s集群中报错的服务。 ​ 官方已经关闭了这个两个issues，1.4.x和2.0.x都有这个问题。 官方的修复思路： ​ 下面这位大佬提交了一段代码，被官方合并到最新的分支上去了，看说明就知道这个是一个极限的操作，降低集群失败的几率 RESET_PEERS(JRaftConstants.RESET_PEERS) {...
Open in Who Shared Issue with article?

Kafka之Consumer使用与基本原理_kafkaconsumer_多动手,勤思考的博客-CSDN博客

|
By import java.time.Duration, import java.util.Arrays, import java.util.Properties, String groupId
| CSDN
session.timeout.ms 最初该参数有两种含义： 第一种是判断consumer group成员是否崩溃的会话超时时间，如果该值设置的过长，那么消费者组协调者(group coordinator)也需要对应的时间才能判断出consumer崩溃， 第二种是consumer消息处理逻辑的最大时间(即单个consumer两次poll的间隔时间)，如果超出这个时间，coordinator会将该消费者踢出group，该消费者负责的分区也将重新分配给其他消费者， 这会引发两种问题，一是不必要的rebalance，因为被踢出的consumer需要重新加入group， 二是consumer被踢出group后处理的消息，无法提交位移，意味着该消息在rebalance后会被重复消费，如果消息处理总是需要很久的时间，那么将引起恶性循环，consumer将无法执行新消息的消费，除非调整参数值。 这种定义，让用户在实际使用中很不方便，可能消息处理逻辑本身就比较久，但是又希望快速检测到consumer的失败，于是在 0.10.1 版本后，该参数仅包含一种意思，...
Open in Who Shared Issue with article?
Show More