简介
该用户还未填写简介
擅长的技术栈
可提供的服务
暂无可提供的服务
1.文件系统 容量 已用 可用 已用占比 挂载点 (列标题) df -h2.du -h --max-depth=1du -h 命令与df -h 命令不同的是 du -h 是对文件和目录所占据的磁盘空间的查看
http://mvnrepository.com/artifact/com.alibaba/fastjson/1.2.45 JSONObject result = JSONObject.parseObject(json);Map map=new HashMap();map.put("total", total);map.put("rows", list);J
Linux打开防火墙,开放相应的端口访问vi /etc/sysconfig/iptables-A INPUT -m state --state NEW -m tcp -p tcp --dport 8161 -j ACCEPT-A INPUT -m state --state NEW -m tcp -p tcp --dport 61616 -j ACCEPT重启防火墙服务service iptabl
1.需要初始化的bean2.把第一步的bean类注入到下面的类3.打印注入的bean结果:①kafkaRulePropertiesKafkaRuleProperties(groupId=GROUP_RULE, topic=cmis_storage_loginfo, servers=vm162centos31:9092,vm162centos11:9092,vm162cent...
错误:Failed to send; nested exception is org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition.找不到推送消息服务器的所在分区,那估计就是kafka挂掉了1.kafka的几个概念:p
1.先看代码不断的去创建kafka发送客户端客户端id,我们指定的cliendId是固定的,在并发量小的时候,创建kafka客户端,指定客户端id,销毁,正常。但并发量大的时候,可能出现上创建cliendId的客户端服务没有来得及销毁,又重新创建了一个2.解决方案,1.不指定固定的clientid,2.保证每一建立连接的clientID唯一,3.把创建clientId的...
kafka是一种分布式的,基于发布/订阅的消息系统。它可以处理消费者在网站中的所有动作流数据。这种动作(网页浏览,搜索和其他用户的行动)是在现代网络上的许多社会功能的一个关键因素。这些数据通常是由于吞吐量的要求而通过处理日志和日志聚合来解决。