Commit 4f681657 by Hemanth Yamijala

ATLAS-912 Update to use Kafka 0.10.0.0 (from 0.9.0.0) (madhan.neethiraj via yhemanth)

parent a2e7738a
......@@ -7,7 +7,7 @@ git clone https://git-wip-us.apache.org/repos/asf/incubator-atlas.git atlas
cd atlas
export MAVEN_OPTS="-Xmx1024m -XX:MaxPermSize=512m" && mvn clean install
export MAVEN_OPTS="-Xmx1536m -XX:MaxPermSize=512m" && mvn clean install
</verbatim>
Once the build successfully completes, artifacts can be packaged for deployment.
......
......@@ -20,6 +20,7 @@ package org.apache.atlas.hook;
import com.google.common.annotations.VisibleForTesting;
import kafka.admin.AdminUtils;
import kafka.admin.RackAwareMode;
import kafka.utils.ZkUtils;
import org.I0Itec.zkclient.ZkClient;
import org.I0Itec.zkclient.ZkConnection;
......@@ -114,7 +115,7 @@ public class AtlasTopicCreator {
int numPartitions = atlasProperties.getInt("atlas.notification.hook.numthreads", 1);
int numReplicas = atlasProperties.getInt("atlas.notification.replicas", 1);
AdminUtils.createTopic(zkUtils, topicName, numPartitions, numReplicas,
new Properties());
new Properties(), RackAwareMode.Enforced$.MODULE$);
LOG.warn("Created topic {} with partitions {} and replicas {}", topicName, numPartitions, numReplicas);
}
......
......@@ -371,7 +371,7 @@
<hadoop.version>2.7.0</hadoop.version>
<hbase.version>1.1.2</hbase.version>
<solr.version>5.1.0</solr.version>
<kafka.version>0.9.0.0</kafka.version>
<kafka.version>0.10.0.0</kafka.version>
<!-- scala versions -->
<scala.version>2.10.4</scala.version>
<scala.binary.version>2.10</scala.binary.version>
......
......@@ -3,6 +3,7 @@ Apache Atlas Release Notes
--trunk - unreleased
INCOMPATIBLE CHANGES:
ATLAS-912 Update to use Kafka 0.10.0.0 (from 0.9.0.0) (madhan.neethiraj via yhemanth)
ATLAS-542 Make qualifiedName and name consistent across all Datasets and Process (sumasai via yhemanth)
ATLAS-716 Entity update/delete notifications (shwethags)
ATLAS-619 Canonicalize hive queries (sumasai)
......
......@@ -43,7 +43,7 @@ public class NotificationHookConsumerKafkaTest {
private KafkaNotification kafkaNotification;
@BeforeTest
public void setup() throws AtlasException {
public void setup() throws AtlasException, InterruptedException {
kafkaNotification = startKafkaServer();
}
......@@ -124,9 +124,10 @@ public class NotificationHookConsumerKafkaTest {
return entity;
}
KafkaNotification startKafkaServer() throws AtlasException {
KafkaNotification startKafkaServer() throws AtlasException, InterruptedException {
KafkaNotification kafkaNotification = (KafkaNotification) notificationInterface;
kafkaNotification.start();
Thread.sleep(2000);
return kafkaNotification;
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment