想做消息的统计与消息传递的水龙头限制开关

1、使用 Strimzi 自带的 KafkaConnect 进行数据交互，或者 使用Kafka Bridge组件对接K8S的外部负载均衡或Ingress（注：在OKD是 Route）, ，可以将KAFKA集群暴露出来使用。2、扩缩容的实现可以通过修改 Broker 的副本数量，执行命令 oc apply -f kafka-cr.yaml -n kafka。此过程需结...

在K8S中部署Redis+MySQL测试工具问题，可以使用以下工具来写 MySQL 和测试 Redis 读性能：MySQL Workbench:用于编写SQL语句的图形化工具，可以连接到MySQL数据库并执行操作。2. Redis-benchmark:用于测试Redis读性能的命令行工具，可以生成随机数据并进行读写操作的性能测试。JM...

出现消息丢失的现象，是KAFKA参数配置失当的问题。譬如：（1） Producer 参数：如果想保证数据绝对不丢失， Producer 需要开启重试逻辑，并且设置 ACKS=all ，如果需要增大吞吐量，可以考虑设置较大的 batch.size （默认为 16K ）。 （2）Partition参数：分区副本数建议为 2 或 3 ，从可靠性考虑，非常...

在容器云环境下性能的影响因素有很多，例如虚机容器相对于裸金属容器就会带来额外的10%-15%的开销，因此从性能的角度，裸金属容器是更好的选择。回到存储，首先为了保证性能，无论是存算一体还是存算分离都建议使用SSD盘来保证性能。在成本方面，服务器本地盘看似便宜，但因为其相对低...

中间件容器化比较让人头疼的就是存储问题。常见存储方案：hostPath，灵活性和安全性都很弱NFS/NAS，存量巨大，性能中等，适合IO不敏感的应用SAN，成本高、管理复杂、供应商多分布式存储，适合通用方案、架构复杂、IO能力看硬件从上面我们能看出，用SAN的性能会比较好，但代价或成本较高。...

 建议先梳理清楚交易的业务特征，和数据流向，现根据需求选择合适的MQ，譬如Kafka和RabbitMQ的功能差异如下图所示： 应用场景确定后，譬如确定合适使用KAFKA，则对此交易数据流的流向、各关联系统的角色进行分析，确认是消息的生产者、还是消费者角色。再根据数据的特征和处理需求，对...

建议先分析和评估业务需求，再决策是否有必要引入消息平台。确定应用场景后，再做消息平台的选型。譬如KAFKA适合用在以下场景：日志处理场景：使用Kafka收集各种业务系统的日志数据，通过Kafka以统一接口服务的方式开放给下游系统消费，进行实时处理和分析。用户数据采集和分发场景：...

war里有个配置文件可以修改

Kafka容器化后，弹性伸缩能力可以通过容器编排平台来实现。在容器化的Kafka中，每个Kafka broker都运行在一个独立的容器中，因此可以通过控制容器的数量来实现Kafka的弹性伸缩。例如，在Kubernetes中，可以使用水平自动伸缩功能来根据Kafka负载自动调整Kafka broker的数量。通过监...