-
Notifications
You must be signed in to change notification settings - Fork 3.6k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[feature][broker] PIP-204: Extensions for broker interceptor #17269
Conversation
@aloyszhang It should be a public API change, the proposal is required so that we can make everyone on the same page that how the new API will be used by users. |
@codelipenghui Thanks, I'll send a discuss email to dev soon. |
Update PIP discuss thread : https://lists.apache.org/thread/3zgpbxffo7gzsb5mdh0sk2rq27bgw2bo |
56ff8fd
to
0486753
Compare
/pulsarbot run-failure-checks |
The vote(https://lists.apache.org/thread/ckxqgoyjkqgbp6szn2vh9ynzbsjxm3yy) for this PIP is now passed. |
pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/BrokerInterceptors.java
Outdated
Show resolved
Hide resolved
pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/BrokerInterceptor.java
Show resolved
Hide resolved
pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/BrokerInterceptor.java
Show resolved
Hide resolved
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java
Outdated
Show resolved
Hide resolved
LGTM |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM +1
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Lgtm
/pulsarbot run-failure-checks |
1 similar comment
/pulsarbot run-failure-checks |
pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/BrokerInterceptors.java
Outdated
Show resolved
Hide resolved
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Producer.java
Outdated
Show resolved
Hide resolved
pulsar-broker/src/test/java/org/apache/pulsar/broker/intercept/CounterBrokerInterceptor.java
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think you have removed the test coverage?
pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/BrokerInterceptors.java
Show resolved
Hide resolved
if (brokerInterceptor != null) { | ||
brokerInterceptor.producerClosed(this, producer, producer.getMetadata()); | ||
} |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looks like we don't need if check here?
which part do you mean? |
06a42b3
to
b264a92
Compare
addefcf
to
af69358
Compare
Fixes #17267
Motivation
extend
BrokerInterceptor
, details see #17267Does this pull request potentially affect one of the following parts:
If
yes
was chosen, please highlight the changesDocumentation
doc-not-needed