diff --git a/datastream-server/src/main/java/com/linkedin/datastream/server/assignment/LoadBasedPartitionAssignmentStrategy.java b/datastream-server/src/main/java/com/linkedin/datastream/server/assignment/LoadBasedPartitionAssignmentStrategy.java
index 7bb25b5ea..3439d9d2b 100644
--- a/datastream-server/src/main/java/com/linkedin/datastream/server/assignment/LoadBasedPartitionAssignmentStrategy.java
+++ b/datastream-server/src/main/java/com/linkedin/datastream/server/assignment/LoadBasedPartitionAssignmentStrategy.java
@@ -102,6 +102,7 @@ public Map<String, Set<DatastreamTask>> assignPartitions(Map<String, Set<Datastr
     // TODO Get task count estimate based on throughput and pick a winner
     LoadBasedTaskCountEstimator estimator = new LoadBasedTaskCountEstimator(_taskCapacityMBps, _taskCapacityUtilizationPct);
     int maxTaskCount = estimator.getTaskCount(clusterThroughputInfo, Collections.emptyList(), Collections.emptyList());
+    LOG.info("Max task count obtained from estimator: {}", maxTaskCount);
 
     // TODO Get unassigned partitions
     // Calculating unassigned partitions
diff --git a/gradle/dependency-versions.gradle b/gradle/dependency-versions.gradle
index 82eb8c538..0a171424e 100644
--- a/gradle/dependency-versions.gradle
+++ b/gradle/dependency-versions.gradle
@@ -1,5 +1,5 @@
 ext {
-    LIKafkaVersion = "1.0.61"
+    LIKafkaVersion = "1.0.65"
     apacheHttpClientVersion = "4.5.3"
     avroVersion = "1.7.7"
     commonsCliVersion = "1.2"