InstrumentedRecordInterceptor does not implement afterRecord() method #10934
Unanswered
phillipdriver
asked this question in
Q&A
Replies: 2 comments
-
I create #10935 to address this |
Beta Was this translation helpful? Give feedback.
0 replies
-
Just to add a bit of an answer to my question, seems Spring added a few new methods to the |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
Is there a good reason as to why InstrumentedRecordInterceptor doesn't implement Spring Kafka's
RecordInterceptor#afterRecord()
method?I've written a simple Spring Boot Kafka consumer app that implements and registers a custom
RecordInterceptor
, however, when instrumenting the app using the Open Telemetry java agent (opentelemetry-javaagent.jar), becauseInstrumentedRecordInterceptor
doesn't implementafterRecord()
the defaultRecordInterceptor#afterRecord()
method is called (which does nothing) rather than calling back into my customRecordInterceptor
.This seems a bit odd?
Beta Was this translation helpful? Give feedback.
All reactions