-
2023.11.04 Spring Security PropagationTIL 2023. 11. 4. 14:46
https://www.baeldung.com/spring-security-async-principal-propagation
Injected dependency in Customized KafkaConsumerInterceptor is NULL with Spring Cloud Stream 3.0.9.RELEASE
I want to inject a bean into the customized ConsumerInterceptor as ConsumerConfigCustomizer is added in Sprint Cloud Stream 3.0.9.RELEASE. However, the injected bean is always NULL. Foo (The depend...
stackoverflow.com
producer와 consumer interceptor는 RecordInterceptor 목적은 비슷하지만 동작하는 곳이 다름,
RecordInterceptor : spring listener container가 consumer record 실행 전후로 가로챔producer와 consumer interceptor: kafka에서 관리함. 그렇기에 bean 주입 불가, 3.0부터는 빈으로 관리 가능.
RecordInterceptor vs consumer interceptor
consumer interceptor는 kafka에서 관리하기 때문에 RecordInterceptor 보다 먼저 동작 함
consumer interceptor에서 걸러지고 RecordInterceptor가 사용함. 차이는 누가 관리하냐의 차이.
https://docs.spring.io/spring-kafka/reference/kafka/producer-interceptor-managed-in-spring.html
Producer Interceptor Managed in Spring :: Spring Kafka
Starting with version 3.0.0, when it comes to a producer interceptor, you can let Spring manage it directly as a bean instead of providing the class name of the interceptor to the Apache Kafka producer configuration. If you go with this approach, then you
docs.spring.io
https://docs.spring.io/spring-kafka/reference/kafka/interceptors.html
Wiring Spring Beans into Producer/Consumer Interceptors :: Spring Kafka
Apache Kafka provides a mechanism to add interceptors to producers and consumers. These objects are managed by Kafka, not Spring, and so normal Spring dependency injection won’t work for wiring in dependent Spring Beans. However, you can manually wire in
docs.spring.io
RecordFilterStrategy로 특정 recod
RecordFilterStrategy (Spring for Apache Kafka 3.0.12 API)
Filter an entire batch of records; to filter all records, return an empty list, not null.
docs.spring.io
'TIL' 카테고리의 다른 글
2023.11.18 ThreadPoolTaskExecutor (0) 2023.11.18 2023.11.05 applicationrunner (0) 2023.11.04 2023.11.02 JVM 메모리 구조 (0) 2023.11.02 상위 1% 엔지니어의 7가지 간단한 습관 (0) 2023.11.01 2023.10.28 spring security ip (0) 2023.10.28