root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: add DEFAULT_PORT for Trogdor Agent and Coordinator (#4674) 

Add a DEFAULT_PORT constant for the Trogdor Agent and Coordinator.

Reviewers: Rajini Sivaram <rajinisivaram@googlemail.com>
This commit is contained in:
Colin Patrick McCabe 2018-03-13 06:15:44 -07:00 committed by Rajini Sivaram
parent 0c00aa0983
commit ec9e8110e3
3 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tools/src/main/java/org/apache/kafka/trogdor/agent/Agent.java
View File

@ -44,6 +44,8 @@ import static net.sourceforge.argparse4j.impl.Arguments.store;
public final class Agent { public final class Agent {
private static final Logger log = LoggerFactory.getLogger(Agent.class); private static final Logger log = LoggerFactory.getLogger(Agent.class);
public static final int DEFAULT_PORT = 8888;
/** /**
* The time at which this server was started. * The time at which this server was started.
*/ */

7
tools/src/main/java/org/apache/kafka/trogdor/common/Node.java
View File

@ -17,6 +17,9 @@
package org.apache.kafka.trogdor.common; package org.apache.kafka.trogdor.common;
import org.apache.kafka.trogdor.agent.Agent;
import org.apache.kafka.trogdor.coordinator.Coordinator;
import java.util.Set; import java.util.Set;
/** /**
@ -34,11 +37,11 @@ public interface Node {
} }
public static int getTrogdorAgentPort(Node node) { public static int getTrogdorAgentPort(Node node) {
return getIntConfig(node, Platform.Config.TROGDOR_AGENT_PORT, 0); return getIntConfig(node, Platform.Config.TROGDOR_AGENT_PORT, Agent.DEFAULT_PORT);
} }
public static int getTrogdorCoordinatorPort(Node node) { public static int getTrogdorCoordinatorPort(Node node) {
return getIntConfig(node, Platform.Config.TROGDOR_COORDINATOR_PORT, 0); return getIntConfig(node, Platform.Config.TROGDOR_COORDINATOR_PORT, Coordinator.DEFAULT_PORT);
} }
} }

2
tools/src/main/java/org/apache/kafka/trogdor/coordinator/Coordinator.java
View File

@ -45,6 +45,8 @@ import static net.sourceforge.argparse4j.impl.Arguments.store;
public final class Coordinator { public final class Coordinator {
private static final Logger log = LoggerFactory.getLogger(Coordinator.class); private static final Logger log = LoggerFactory.getLogger(Coordinator.class);
public static final int DEFAULT_PORT = 8889;
/** /**
* The start time of the Coordinator in milliseconds. * The start time of the Coordinator in milliseconds.
*/ */