diff --git a/src/main/java/io/ebeanservice/elastic/support/BaseHttpMessageSender.java b/src/main/java/io/ebeanservice/elastic/support/BaseHttpMessageSender.java
index a75d082..cbd3995 100644
--- a/src/main/java/io/ebeanservice/elastic/support/BaseHttpMessageSender.java
+++ b/src/main/java/io/ebeanservice/elastic/support/BaseHttpMessageSender.java
@@ -196,7 +196,7 @@ public IndexMessageResponse clearScrollIds(Set<String> scrollIds) throws IOExcep
   @Override
   public IndexMessageResponse getDocSource(String indexName, String docId) throws IOException {
 
-    String url = baseUrl + indexName + "/_doc/" + docId + "/_source";
+    String url = baseUrl + indexName + "/_source/" + docId;// + "/_source";
 
     Request request = new Request.Builder().url(url).get().build();
     if (logger.isLoggable(DEBUG)) {