自定義消費者和生產者配置

如果您想對 Kafka 中用於建立 ConsumerFactoryProducerFactory 的消費者和生產者配置進行高階自定義,您可以實現以下自定義器(customizer)。

  • ConsumerConfigCustomizer

  • ProducerConfigCustomizer

這兩個介面都提供了一種配置用於消費者和生產者屬性的配置對映(config map)的方式。例如,如果您想訪問在應用層面定義的 bean,可以在 configure 方法的實現中注入它。當 Binder 檢測到這些自定義器作為 bean 可用時,它將在建立消費者和生產者工廠之前立即呼叫 configure 方法。

這兩個介面還提供對繫結(binding)名稱和目的地(destination)名稱的訪問,以便在自定義生產者和消費者屬性時可以訪問它們。