add position_file parameter

zendesk · Mar 9, 2015 · 6339da9 · 6339da9
1 parent 25e5c59
commit 6339da9
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/main/java/com/zendesk/maxwell/MaxwellConfig.java b/src/main/java/com/zendesk/maxwell/MaxwellConfig.java
@@ -77,6 +77,7 @@ private void parseOptions(String [] argv) {
 		parser.accepts( "user" ).withRequiredArg();
 		parser.accepts( "port" ).withRequiredArg();
 		parser.accepts( "producer" ).withRequiredArg();
+		parser.accepts( "position_file" ).withRequiredArg();
 		parser.accepts( "kafka.bootstrap.servers" ).withRequiredArg();
 
 		OptionSet options = parser.parse(argv);
@@ -91,6 +92,8 @@ private void parseOptions(String [] argv) {
 			this.mysqlPort = Integer.valueOf((String) options.valueOf("port"));
 		if ( options.has("producer"))
 			this.producerType = (String) options.valueOf("producer");
+		if ( options.has("position_file"))
+			this.currentPositionFile = (String) options.valueOf("position_file");
 
 		if ( options.has("kafka.bootstrap.servers"))
 			this.kafkaProperties.setProperty("bootstrap.servers", (String) options.valueOf("kafka.bootstrap.servers"));