Validate X-Druid-Task-Id header in request/response and support retry…

…ing on outdated TaskLocation information, add KafkaIndexTaskClient unit tests (apache#3006) * validate X-Druid-Task-Id header in request and add header to response * modify KafkaIndexTaskClient to take a TaskLocationProvider as the TaskLocation may not remain constant
jackar · May 26, 2016 · 3ef24c0 · 3ef24c0
1 parent b5bd406
commit 3ef24c0
Show file tree

Hide file tree

Showing 12 changed files with 1,133 additions and 229 deletions.
diff --git a/extensions-core/kafka-indexing-service/pom.xml b/extensions-core/kafka-indexing-service/pom.xml
@@ -46,6 +46,12 @@
       <version>0.9.1-SNAPSHOT</version>
       <scope>provided</scope>
     </dependency>
+    <dependency>
+      <groupId>io.netty</groupId>
+      <artifactId>netty</artifactId>
+      <version>3.10.4.Final</version>
+      <scope>provided</scope>
+    </dependency>
     <dependency>
       <groupId>org.apache.kafka</groupId>
       <artifactId>kafka-clients</artifactId>