Binyao Jiang created SAMZA-2569:
-----------------------------------
Summary: Add features into StreamAppender
Key: SAMZA-2569
URL: https://issues.apache.org/jira/browse/SAMZA-2569
Project: Samza
Issue Type: New Feature
Reporter: Binyao Jiang
Issues:
# StreamAppender is not extend-friendly. It is hard to extend this class with
minor code changes.
# StreamAppender only collects metrics but does not get metrics reported to
MetricsReporter.
# Lack log message count and bytes calculation in StreamAppender's metrics
Changes:
# Rewrite StreamAppender to expose private members/functions as protected and
split some heavy functions into small trunks.
# Add metrics reporter to report the metrics we collect locally
# Add those new metrics into StreamAppender
Tests:
# Unit tests pass for updated StreamAppender
# {{./gradlew build.}}
Upgrade/usage instructions:
1. If users write new appender or extends existing StreamAppender for own use
cases, feel free to update their appender code to extend new StreamAppender to
make code neater.
2. If users want to report these collected metrics through metrics reporter,
add metrics reporter related configs (See MetricsConfig.java for more details)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
