Additional Annotations for Kafka Trigger and Output Binding (#200)

* Adding annotations for Kafka trigger and output

* Correcting case for lingerMs

* Adding avroschema annotation for kafka output

* Correcting Avro Schema description for output

Author: jainharsh98

src/main/java/com/microsoft/azure/functions/annotation/KafkaOutput.java

@@ -190,4 +190,46 @@
      * @return The ssl key password.
      */
     String sslKeyPassword() default "";
+
+    /**
+     * linger.MS property provides the time between batches of messages
+     * being sent to cluster. Larger value allows more batching that 
+     * results in high throughput.
+     * 
+     * @return value of linger.ms property.
+     */
+    int lingerMs() default 5;
+
+    /**
+     * Avro schema for generic record serialization
+     * default ""
+     *
+     * @return the avro schema
+     */
+    String avroSchema() default "";
+
+    /**
+     * URL for the Avro Schema Registry
+     * default ""
+     *
+     * @return the avro schema registry url
+     */
+    String schemaRegistryUrl() default "";
+
+    /**
+     * Username for the Avro Schema Registry
+     * default ""
+     *
+     * @return the avro schema registry username
+     */
+    String schemaRegistryUsername() default "";
+
+    /**
+     * Password for the Avro Schema Registry
+     * default ""
+     *
+     * @return the avro schema registry password
+     */
+    String schemaRegistryPassword() default "";
+
 }

src/main/java/com/microsoft/azure/functions/annotation/KafkaTrigger.java

@@ -181,4 +181,35 @@
      * @return the avro schema
      */
     String avroSchema() default "";
+
+    /***
+     * 
+     * @return
+    */
+    int lagThreshold() default 1000;
+
+    /**
+     * URL for the Avro Schema Registry
+     * default ""
+     *
+     * @return the avro schema registry url
+     */
+    String schemaRegistryUrl() default "";
+
+    /**
+     * Username for the Avro Schema Registry
+     * default ""
+     *
+     * @return the avro schema registry username
+     */
+    String schemaRegistryUsername() default "";
+
+    /**
+     * Password for the Avro Schema Registry
+     * default ""
+     *
+     * @return the avro schema registry password
+     */
+    String schemaRegistryPassword() default "";
+
 }