1.0.0 release

Author: asaintsever

connector/.gitignore renamed to .gitignore

@@ -1,6 +1,6 @@
 FROM maven:3.8.1-openjdk-11 as build
 
-COPY connector/ /connector/
+COPY . /connector/
 
 RUN cd /connector && mvn clean package
 

Dockerfile

@@ -1,6 +1,7 @@
 SHELL=/bin/bash
 
-FQIN:=asaintsever/kafkaconnect-httpsinkconnector
+VERSION:=1.0.0
+FQIN:=asaintsever/kafkaconnect-httpsinkconnector:$(VERSION)
 CONTAINER_RUNTIME:=$(shell command -v docker 2> /dev/null || echo podman)	# Use docker by default if found, else try podman
 
 .SILENT: ;  	# No need for @
@@ -11,7 +12,6 @@ CONTAINER_RUNTIME:=$(shell command -v docker 2> /dev/null || echo podman)	# Use
 
 connector-archive:
 	echo "Building Kafka Connect connector archive ..."
-	cd connector
 	mvn clean package
 
 connector-image:

Makefile

@@ -2,7 +2,7 @@
 
 The HTTP Sink Connector is a sample implementation of a Kafka Connect connector. This is a `sink` connector, reading events from kafka topics to send them to some HTTP endpoint.
 
-Using connector's configuration, you can set the list of Kafka topics to read from and the target HTTP endpoint (only one supported is this implementation). You can also provide your own event formatters (see default [PassthroughStringEventFormatter](connector/src/main/java/asaintsever/httpsinkconnector/event/formatter/PassthroughStringEventFormatter.java) as an example) and HTTP authentication providers (see default [NoAuthenticationProvider](connector/src/main/java/asaintsever/httpsinkconnector/http/authentication/NoAuthenticationProvider.java) and [ConfigAuthenticationProvider](connector/src/main/java/asaintsever/httpsinkconnector/http/authentication/ConfigAuthenticationProvider.java) as examples).
+Using connector's configuration, you can set the list of Kafka topics to read from and the target HTTP endpoint (only one supported is this implementation). You can also provide your own event formatters (see default [PassthroughStringEventFormatter](src/main/java/asaintsever/httpsinkconnector/event/formatter/PassthroughStringEventFormatter.java) as an example) and HTTP authentication providers (see default [NoAuthenticationProvider](src/main/java/asaintsever/httpsinkconnector/http/authentication/NoAuthenticationProvider.java) and [ConfigAuthenticationProvider](src/main/java/asaintsever/httpsinkconnector/http/authentication/ConfigAuthenticationProvider.java) as examples).
 
 This connector will batch events before sending them in order to reduce the number of calls and not overwhelm the HTTP endpoint.
 
@@ -137,8 +137,8 @@ ${TOOLSPOD} "curl -s -X GET http://httpsinkconnector-connect-api:8083/connectors
     ```sh
     # Post single events
     # (do not forget the 'jq . -c' part for the JSON sample as we must provide a one line string otherwise kcat will interpret each line of the file as a new value ...)
-    cat test/sample.txt | ${KCATPOD} "kcat -b local-kafka-brokers:9092 -P -t raw-events"
-    cat test/sample.json | jq . -c | ${KCATPOD} "kcat -b local-kafka-brokers:9092 -P -t json-events-1"
+    cat samples/sample.txt | ${KCATPOD} "kcat -b local-kafka-brokers:9092 -P -t raw-events"
+    cat samples/sample.json | jq . -c | ${KCATPOD} "kcat -b local-kafka-brokers:9092 -P -t json-events-1"
     ```
 
     Look at the HTTP Sink connector's log (you should see outputs from our test HTTP endpoint):
@@ -152,8 +152,8 @@ ${TOOLSPOD} "curl -s -X GET http://httpsinkconnector-connect-api:8083/connectors
     ```sh
     # Post batches of events
     # (each event must be on one line in the batch file)
-    cat test/sample.txt.batch | ${KCATPOD} "kcat -b local-kafka-brokers:9092 -P -t raw-events"
-    cat test/sample.json.batch | ${KCATPOD} "kcat -b local-kafka-brokers:9092 -P -t json-events-1"
+    cat samples/sample.txt.batch | ${KCATPOD} "kcat -b local-kafka-brokers:9092 -P -t raw-events"
+    cat samples/sample.json.batch | ${KCATPOD} "kcat -b local-kafka-brokers:9092 -P -t json-events-1"
     ```
 
     Look at the HTTP Sink connector's log (you should see outputs from our test HTTP endpoint with events sent in batch):

README.md

@@ -8,7 +8,7 @@ metadata:
     # needing to call the Connect REST API directly
     strimzi.io/use-connector-resources: "true"
 spec:
-  image: asaintsever/kafkaconnect-httpsinkconnector
+  image: asaintsever/kafkaconnect-httpsinkconnector:1.0.0
   replicas: 1
   bootstrapServers: "PLAINTEXT://local-kafka-brokers:9092"
   config:

deploy/k8s/httpsink-kafkaconnect.yaml

@@ -14,18 +14,18 @@
 	    <maven.surefire.plugin.version>2.22.0</maven.surefire.plugin.version>
 	    <maven.failsafe.plugin.version>2.22.0</maven.failsafe.plugin.version>
 	    <maven.kafka.connect.plugin.version>0.12.0</maven.kafka.connect.plugin.version>
-		<java.version>11</java.version>
+	    <java.version>11</java.version>
 
-		<slf4j.version>1.7.30</slf4j.version>
-		<kafka.version>2.7.0</kafka.version>
-		<!-- Not needed except if our connector has to deal with AVRO directly
-		<kafka.avro.version>6.0.1</kafka.avro.version>
-		<avro.version>1.9.2</avro.version>
-		-->
-		<jackson.version>2.10.2</jackson.version>
+	    <slf4j.version>1.7.30</slf4j.version>
+	    <kafka.version>2.7.0</kafka.version>
+	    <!-- Not needed except if our connector has to deal with AVRO directly
+	    <kafka.avro.version>6.0.1</kafka.avro.version>
+	    <avro.version>1.9.2</avro.version>
+	    -->
+	    <jackson.version>2.10.2</jackson.version>
 
-		<junit.version>5.6.2</junit.version>
-		<mockito.version>3.3.3</mockito.version>
+	    <junit.version>5.6.2</junit.version>
+	    <mockito.version>3.3.3</mockito.version>
 	</properties>
 
 	<repositories>
@@ -35,7 +35,15 @@
             <url>https://packages.confluent.io/maven/</url>
         </repository>
     </repositories>
-    
+
+    <licenses>
+        <license>
+            <name>Apache License, Version 2.0</name>
+            <url>https://www.apache.org/licenses/LICENSE-2.0.txt</url>
+            <distribution>manual</distribution>
+        </license>
+    </licenses>
+
 	<dependencies>
 	    <!-- 
 	    Kafka Connect API & Runtime *must* not be part of our plugin/package (see Kafka Connect doc): 
@@ -176,7 +184,7 @@
                             <sourceUrl>https://github.com/asaintsever/kafka-connect-http-sink/blob/main/connector</sourceUrl>
                             <dockerNamespace>asaintsever</dockerNamespace>
                             <dockerName>kafkaconnect-httpsinkconnector</dockerName>
-                            <dockerTag>latest</dockerTag>
+                            <dockerTag>${project.version}</dockerTag>
                             <componentTypes>
                                 <componentType>sink</componentType>
                             </componentTypes>