diff --git a/docs/api/tutorials/tags.md b/docs/api/tutorials/tags.md
index b2234bf00bcb9..24d583dc26dac 100644
--- a/docs/api/tutorials/tags.md
+++ b/docs/api/tutorials/tags.md
@@ -78,6 +78,14 @@ Expected Response:
 
 </TabItem>
 
+<TabItem value="java" label="Java">
+
+```java
+{{ inline /metadata-integration/java/examples/src/main/java/io/datahubproject/examples/TagCreate.java show_path_as_comment }}
+```
+
+</TabItem>
+
 <TabItem value="python" label="Python">
 
 ```python
diff --git a/metadata-integration/java/examples/src/main/java/io/datahubproject/examples/TagCreate.java b/metadata-integration/java/examples/src/main/java/io/datahubproject/examples/TagCreate.java
new file mode 100644
index 0000000000000..077489a9e02d9
--- /dev/null
+++ b/metadata-integration/java/examples/src/main/java/io/datahubproject/examples/TagCreate.java
@@ -0,0 +1,40 @@
+package io.datahubproject.examples;
+
+import com.linkedin.tag.TagProperties;
+import datahub.client.MetadataWriteResponse;
+import datahub.client.rest.RestEmitter;
+import datahub.event.MetadataChangeProposalWrapper;
+
+import java.io.IOException;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.Future;
+
+public class TagCreate {
+    
+    private TagCreate() {
+
+    }
+
+    public static void main(String[] args) throws IOException, ExecutionException, InterruptedException {
+        TagProperties tagProperties = new TagProperties()
+                .setName("Deprecated")
+                .setDescription("Having this tag means this column or table is deprecated.");
+
+        MetadataChangeProposalWrapper mcpw = MetadataChangeProposalWrapper.builder()
+                .entityType("tag")
+                .entityUrn("urn:li:tag:deprecated")
+                .upsert()
+                .aspect(tagProperties)
+                .build();
+
+        String token = "";
+        RestEmitter emitter = RestEmitter.create(
+                b -> b.server("http://localhost:8080")
+                        .token(token)
+        );
+        Future<MetadataWriteResponse> response = emitter.emit(mcpw, null);
+        System.out.println(response.get().getResponseContent());
+
+
+    }
+}