*遇到kafka的问题千万不要直接删除kafka-manager里的topic，会导致topic不能再使用，首先需要确认kafka是否可用*一、部署机器test33-1test34-2test35-3二、排查问题1、33环境不能用topic能用，tcp报错如下图（1）验证kafka是否可用开启一个生产者和消费者查看kafka是否正常，如下路径：cd /usr/local/kafka/1/bin生产

以下给出一个参考示例，但具体的某些细节的处理还需要根据自己的业务自行抉择实现思路，通过 consumer.wakeup() 方法让 poll 方法抛出异常，然后捕获异常，退出《kafka权威指南》 第 64 页也有给出示例，有兴趣的可以找来看看// 消费线程privateThread consumerThread;// 线程名称，自己设置下privateString threadName;priv

以下以33环境为例基本情况broker地址:10.30.200.155:15386topic:DC_REACH_DESTINATION_EVENT_NOTIFY检查kafkahttps://test-kafka.xxxkeji.cn/clusters/test33查看是否有kafka挂了例如,kafka broker为2,正常33,44 kafka数量为3, stable为2如果数量小于既定kaf

合理的参数设置可以为你的redis客户端保驾护航，下面将对lettuce使用的一些重要参数进行说明和建议序号参数名含义默认值使用建议序号参数名含义默认值使用建议1enableAllAdaptiveRefreshTriggersredis

如果数量小于既定kafka broker数说明kafka挂了,需要重启kafkakafka.1.server status #检查kafka.1.server start #启动如果无上述命令,执行 history|grep kafka , 查看kafka相关启动命令如果执行命令无法启动kafka,极有可能是内存不足或者磁盘不足内存不足执行top命令,看哪个应用占的比较多,能干掉的先干掉如果磁盘不

1：查看集群信息：cluster info> cluster infocluster_state:ok #集群状态，ok：在线；fail：槽未分配或则无法联系到多数master节点cluster_slots_assigned:16384 #已分配到集群节点的哈希槽数量（不是没有被绑定的数量）。cluster_slots_ok:16384 #正确分配的槽位，哈希槽状态不是FAIL 和 PFAI

@Configurationpublic class RedisConfig {@Resourceprivate RedisProperties redisProperties;@Value("${spring.redis.hotwheel.username}")private StringredisUserName;@Beanpublic <K,V> RedisTemplate&lt

说明Redis Cluster 在5.0之后取消了ruby脚本redis-trib.rb的支持（手动命令行添加集群的方式不变），集合到redis-cli里，避免了再安装ruby的相关环境。直接使用redis-clit的参数--cluster来取代。为方便后面查询就说明下如何使用该命令进行Cluster的创建和管理redis-cli --cluster helpredis-cli--cluster