API 与 event contract 的兼容性保障按问答拆开:BFF 对外用 oasdiff 守 OpenAPI spec,内部 BFF 到 MS、MS 到 MS 用 JSON Schema 快照补 japicmp 的盲区,Kafka 事件再加 per-event schemaVersion。
Posts for: #kafka
Java 项目怎么做 contract testing:一次 Spring Cloud Contract 实践
基于 java-contract 仓库的工程复盘:REST API 和 Kafka 消息 contract 如何在 Java 25 + Spring Boot 3.5 + Maven 多模块项目里分别落地,producer 验证、consumer stubs 和 CI Quality Gates 如何串起来。
Spring Boot 3.5 Tracing:接完之后,PII 和采样怎么管
结合一次 Spring Boot 3.5 tracing 接入:自动配置覆盖范围、自定义埋点、Kafka/Redis/DB 组件接入、采样策略、PII 处理,以及用 ArchUnit 约束常见误用。
Confluent Kafka topic 该分多少分区:按业务规模算,再对成本和连接数
Confluent Kafka 的 topic 分区数按当前业务规模假设算了一轮,起步先按 12 个分区配置。
How Many Kafka Connections Does Your Spring Boot App Actually Use?
A practical formula for calculating Kafka TCP connection counts in Spring Boot, covering producers, consumers, AdminClient, and how to choose the right Confluent Cloud plan.
Spring Boot 3.5 下的 Kafka 配置:消费者并发模型、acks/retries、序列化选型与 DLQ
Spring Boot 3.5 加 Spring Kafka 3.3 把 Kafka 该配的基本都配得起来,这套仓库落地的是消费者并发模型、生产者的 acks 与 retries、序列化选型、offset 提交策略、死信处理和 @RetryableTopic。
Spring Boot 3.5 + Java 25 + Cloud Native 系列(五):事件驱动架构
Shop Platform 的事件驱动这层:Kafka 加 Transactional Outbox 保证投递,EventEnvelope 统一信封,IdempotencyGuard 管幂等,重试与 DLQ 各有策略,同步 Saga 和异步事件按场景分工。