Merge pull request #542 from zendesk/avoid_regexp

don't regex the topic unless needed
zendesk · Jan 21, 2017 · cfe8095 · cfe8095
2 parents 6ad4406 + fa1bccc
commit cfe8095
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/main/java/com/zendesk/maxwell/producer/MaxwellKafkaProducer.java b/src/main/java/com/zendesk/maxwell/producer/MaxwellKafkaProducer.java
@@ -62,6 +62,7 @@ public class MaxwellKafkaProducer extends AbstractAsyncProducer {
 	private final MaxwellKafkaPartitioner partitioner;
 	private final MaxwellKafkaPartitioner ddlPartitioner;
 	private final KeyFormat keyFormat;
+	private final boolean interpolateTopic;
 
 	public MaxwellKafkaProducer(MaxwellContext context, Properties kafkaProperties, String kafkaTopic) {
 		super(context);
@@ -71,6 +72,7 @@ public MaxwellKafkaProducer(MaxwellContext context, Properties kafkaProperties,
 			this.topic = "maxwell";
 		}
 
+		this.interpolateTopic = kafkaTopic.contains("%{");
 		this.kafka = new KafkaProducer<>(kafkaProperties, new StringSerializer(), new StringSerializer());
 
 		String hash = context.getConfig().kafkaPartitionHash;
@@ -97,7 +99,10 @@ private Integer getNumPartitions(String topic) {
 	}
 
 	private String generateTopic(String topic, RowMap r){
-		return topic.replaceAll("%\\{database\\}", r.getDatabase()).replaceAll("%\\{table\\}", r.getTable());
+		if ( interpolateTopic )
+			return topic.replaceAll("%\\{database\\}", r.getDatabase()).replaceAll("%\\{table\\}", r.getTable());
+		else
+			return topic;
 	}
 
 	@Override