You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "Boris Shkolnik (JIRA)" <ji...@apache.org> on 2018/09/26 01:33:00 UTC
[jira] [Created] (SAMZA-1912) improve code style for
KafkaSystemConsumer(Proxy)
Boris Shkolnik created SAMZA-1912:
-------------------------------------
Summary: improve code style for KafkaSystemConsumer(Proxy)
Key: SAMZA-1912
URL: https://issues.apache.org/jira/browse/SAMZA-1912
Project: Samza
Issue Type: Bug
Reporter: Boris Shkolnik
Assignee: Boris Shkolnik
These are some code style improvements from PR #624:
1. KafkaSystemConsumer and KafkaConsumerProxy:
LOG.info("{}: Created KafkaConsumerProxy {} ", this, proxy);
Would prefer to log everything in this class as "Created KafkaConsumerProxy {} for systemName {}" for consistency with rest of the codebase.
2.
KafkaSystemConsumer:startSubscription
Can this entire method be in KafkaConsumerProxy to consolidate consumer management in one class (as the name KafkaConsumerProxy implies).
3.
KafkaSystemConsumer.java
Same comment as other class: prefer ordering methods logically by how they're used. E.g., it makes more sense to order them as 'register, start, poll, stop' etc than the current order of 'start, stop, register, poll'. Also, prefer ordering methods by visibility: public, protected then private methods.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)