配置类@BeanKafkaDefaultKafkaProducerFactoryCustomizer kafkaDefaultKafkaProducerFactoryCustomizer() {return new KafkaDefaultKafkaProducerFactoryCustomizer(objectMapper());}@BeanKafkaDefaultKafkaConsumerFa

IoT场景流计算在IoT场景有时我们想看某个设备的每小时/每天的工时信息. 电压的平均值.油耗的总值 平均值 等这时我们可以用一些流计算框架来做例如flink sparkstream 等.但是如果用flink来做的话 每台设备一个时间窗口 如果设备量很多十万 二十万的话窗口会很多.会存在窗口风暴的问题.Redis 流计算如果说我们只想看某设备每天的工时信息.不妨也可以使用redis 的 ...

获取所有服务列表com.alibaba.cloud.nacos.discovery.NacosDiscoveryClient#getServices发一个grpc请求获取服务列表根据serviceId获取服务列表com.alibaba.nacos.client.naming.NacosNamingService#selectInstances()com.alibaba.nacos.client.n

k8s 以sidecar形式部署java应用

云原生下本地开发最近把公司微服务开发环境都迁移到k8s中. 之前部署在一台实体机上面. 记录下踩到的坑技术栈Nacos 2.0.2SpringCloud 2020.01问题nacos 2.0.2 使用grpc 需要暴露更多端口. 且需要tcp代理. ingress 解决不了问题.本地服务调用与开发环境通用服务之间服务调用的网络隔离问题.nacos 问题.使用 kubefwd 解决服务注册地址直接写