-
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
Send Log statements to log Topic for Java Functions #1447
Conversation
retest this please |
@@ -262,10 +268,12 @@ public void run() { | |||
} | |||
long processAt = System.currentTimeMillis(); | |||
stats.incrementProcessed(processAt); | |||
addLogTopicHandler(); |
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.
this seems to be done at per message?
Can we configure the log handler at the beginning of the instance and remove it at the end?
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.
We need to send only the log messages inside the function to the log topic. Other logging messages inside the java instance or runtime should not be sent. Thats why we need to do this on a per message basis.
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.
okay... I am not sure if there is any performance penalty here. but okay to me for now.
Motivation
Currently logTopic directive only works for Python functions. This pr brings that functionality to Java Functions as well.
Modifications
Describe the modifications you've done.
Result
After your change, what will change.