flume-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zhenzhao wang <wzzdrea...@gmail.com>
Subject Re: Review Request 67917: Adding Register Service Component and Zookeeper registration for service discovery
Date Fri, 13 Jul 2018 22:06:47 GMT

-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/67917/
-----------------------------------------------------------

(Updated July 13, 2018, 10:06 p.m.)


Review request for Flume and Ferenc Szabo.


Repository: flume-git


Description
-------

We're going to introduce following feature/function in the patch:

1. Adding a register service component interface so developer could develop their own agent
service registration machoism for source process.
2. A zookeeper register service which will create node on Zookeeper with service url. So clients
could use zookeeper to find available flume agents.


Diffs
-----

  flume-ng-configuration/src/main/java/org/apache/flume/conf/BasicConfigurationConstants.java
3f23e62 
  flume-ng-configuration/src/main/java/org/apache/flume/conf/ComponentConfiguration.java b7bab15

  flume-ng-configuration/src/main/java/org/apache/flume/conf/ComponentConfigurationFactory.java
f1e3a8c 
  flume-ng-configuration/src/main/java/org/apache/flume/conf/FlumeConfiguration.java e6c7875

  flume-ng-configuration/src/test/java/org/apache/flume/conf/TestFlumeConfiguration.java a881d00

  flume-ng-configuration/src/test/java/org/apache/flume/conf/TestFlumeConfigurationConfigFilter.java
ada2d8f 
  flume-ng-core/pom.xml 3d72aba 
  flume-ng-core/src/main/java/org/apache/flume/interceptor/InterceptorBuilderFactory.java
7c64613 
  flume-ng-core/src/main/java/org/apache/flume/register/service/AbstractRegisterService.java
PRE-CREATION 
  flume-ng-core/src/main/java/org/apache/flume/register/service/RegisterService.java PRE-CREATION

  flume-ng-core/src/main/java/org/apache/flume/register/service/RegisterServiceFactory.java
PRE-CREATION 
  flume-ng-core/src/main/java/org/apache/flume/register/service/ZooKeeperRegisterService.java
PRE-CREATION 
  flume-ng-core/src/test/java/org/apache/flume/register/service/TestZooKeeperRegisterService.java
PRE-CREATION 
  flume-ng-doc/sphinx/FlumeUserGuide.rst af91f9e 
  flume-ng-embedded-agent/src/test/java/org/apache/flume/agent/embedded/TestEmbeddedAgentEmbeddedSource.java
ae59444 
  flume-ng-node/src/main/java/org/apache/flume/node/AbstractConfigurationProvider.java 130bc64

  flume-ng-node/src/main/java/org/apache/flume/node/Application.java 7111f60 
  flume-ng-node/src/main/java/org/apache/flume/node/MaterializedConfiguration.java fa3ef55

  flume-ng-node/src/main/java/org/apache/flume/node/SimpleMaterializedConfiguration.java fa58dff



Diff: https://reviews.apache.org/r/67917/diff/1/


Testing
-------

1. Unit test done. 
2. It had been used internally for years, however there're difference between this patch and
our internal patch.


Thanks,

zhenzhao wang


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message