src/main/java/org/embulk/input/PostgreSQLInputPlugin.java in embulk-input-postgresql-0.7.2 vs src/main/java/org/embulk/input/PostgreSQLInputPlugin.java in embulk-input-postgresql-0.7.3

@@ -46,10 +46,14 @@
         public String getSchema();
 
         @Config("ssl")
         @ConfigDefault("false")
         public boolean getSsl();
+
+        @Config("application_name")
+        @ConfigDefault("\"embulk-input-postgresql\"")
+        public String getApplicationName();
     }
 
     @Override
     protected Class<? extends PluginTask> getTaskClass()
     {
@@ -79,9 +83,11 @@
             //      see embulk-input-ftp for SSL implementation.
             props.setProperty("ssl", "true");
             props.setProperty("sslfactory", "org.postgresql.ssl.NonValidatingFactory");  // disable server-side validation
         }
         // setting ssl=false enables SSL. See org.postgresql.core.v3.openConnectionImpl.
+
+        props.setProperty("ApplicationName", t.getApplicationName());
 
         props.putAll(t.getOptions());
 
         Connection con = driver.connect(url, props);
         try {