added copyright to some schema registry files and (confluentinc#812)

moved copyright position on top of the files
with one newline before package definition to avoid
being interpreted as the package's documentation

Author: emasab

examples/admin_create_acls/admin_create_acls.go

@@ -1,6 +1,3 @@
-// Create ACLs
-package main
-
 /**
  * Copyright 2022 Confluent Inc.
  *
@@ -17,6 +14,9 @@ package main
  * limitations under the License.
  */
 
+// Create ACLs
+package main
+
 import (
 	"context"
 	"fmt"

examples/admin_create_topic/admin_create_topic.go

@@ -1,6 +1,3 @@
-// Create topic
-package main
-
 /**
  * Copyright 2018 Confluent Inc.
  *
@@ -17,6 +14,9 @@ package main
  * limitations under the License.
  */
 
+// Create topic
+package main
+
 import (
 	"context"
 	"fmt"

examples/admin_delete_acls/admin_delete_acls.go

@@ -1,6 +1,3 @@
-// Delete ACLs
-package main
-
 /**
  * Copyright 2022 Confluent Inc.
  *
@@ -17,6 +14,9 @@ package main
  * limitations under the License.
  */
 
+// Delete ACLs
+package main
+
 import (
 	"context"
 	"fmt"

examples/admin_delete_topics/admin_delete_topics.go

@@ -1,6 +1,3 @@
-// Delete topics
-package main
-
 /**
  * Copyright 2018 Confluent Inc.
  *
@@ -17,6 +14,9 @@ package main
  * limitations under the License.
  */
 
+// Delete topics
+package main
+
 import (
 	"context"
 	"fmt"

examples/admin_describe_acls/admin_describe_acls.go

@@ -1,6 +1,3 @@
-// Describe ACLs
-package main
-
 /**
  * Copyright 2022 Confluent Inc.
  *
@@ -17,6 +14,9 @@ package main
  * limitations under the License.
  */
 
+// Describe ACLs
+package main
+
 import (
 	"context"
 	"fmt"

examples/admin_describe_config/admin_describe_config.go

@@ -1,6 +1,3 @@
-// List current configuration for a cluster resource
-package main
-
 /**
  * Copyright 2018 Confluent Inc.
  *
@@ -17,6 +14,9 @@ package main
  * limitations under the License.
  */
 
+// List current configuration for a cluster resource
+package main
+
 import (
 	"context"
 	"fmt"

examples/avro_generic_consumer_example/avro_generic_consumer_example.go

@@ -1,6 +1,3 @@
-// Example function-based high-level Apache Kafka consumer
-package main
-
 /**
  * Copyright 2022 Confluent Inc.
  *
@@ -17,6 +14,9 @@ package main
  * limitations under the License.
  */
 
+// Example function-based high-level Apache Kafka consumer
+package main
+
 // consumer_example implements a consumer using the non-channel Poll() API
 // to retrieve messages and events.
 

examples/avro_generic_producer_example/avro_generic_producer_example.go

@@ -1,6 +1,3 @@
-// Example function-based Apache Kafka producer
-package main
-
 /**
  * Copyright 2022 Confluent Inc.
  *
@@ -17,6 +14,9 @@ package main
  * limitations under the License.
  */
 
+// Example function-based Apache Kafka producer
+package main
+
 import (
 	"fmt"
 	"os"

examples/avro_specific_consumer_example/avro_specific_consumer_example.go

@@ -1,6 +1,3 @@
-// Example function-based high-level Apache Kafka consumer
-package main
-
 /**
  * Copyright 2022 Confluent Inc.
  *
@@ -17,6 +14,9 @@ package main
  * limitations under the License.
  */
 
+// Example function-based high-level Apache Kafka consumer
+package main
+
 // consumer_example implements a consumer using the non-channel Poll() API
 // to retrieve messages and events.
 

examples/confluent_cloud_example/confluent_cloud_example.go

@@ -1,12 +1,3 @@
-// This is a simple example demonstrating how to produce a message to
-// a topic, and then reading it back again using a consumer. The topic
-// belongs to a Apache Kafka cluster from Confluent Cloud. For more
-// information about Confluent Cloud, please visit:
-//
-// https://www.confluent.io/confluent-cloud/
-
-package main
-
 /**
  * Copyright 2018 Confluent Inc.
  *
@@ -23,6 +14,15 @@ package main
  * limitations under the License.
  */
 
+// This is a simple example demonstrating how to produce a message to
+// a topic, and then reading it back again using a consumer. The topic
+// belongs to a Apache Kafka cluster from Confluent Cloud. For more
+// information about Confluent Cloud, please visit:
+//
+// https://www.confluent.io/confluent-cloud/
+
+package main
+
 import (
 	"context"
 	"fmt"

examples/consumer_example/consumer_example.go

@@ -1,6 +1,3 @@
-// Example function-based high-level Apache Kafka consumer
-package main
-
 /**
  * Copyright 2016 Confluent Inc.
  *
@@ -17,6 +14,9 @@ package main
  * limitations under the License.
  */
 
+// Example function-based high-level Apache Kafka consumer
+package main
+
 // consumer_example implements a consumer using the non-channel Poll() API
 // to retrieve messages and events.
 

examples/consumer_offset_metadata/consumer_offset_metadata.go

@@ -1,6 +1,3 @@
-// Example Apache Kafka consumer that commit offset with metadata
-package main
-
 /**
  * Copyright 2019 Confluent Inc.
  *
@@ -17,6 +14,9 @@ package main
  * limitations under the License.
  */
 
+// Example Apache Kafka consumer that commit offset with metadata
+package main
+
 // consumer_offset_metadata implements a consumer that commit offset with metadata that represents the state
 // of the partition consumer at that point in time. The metadata string can be used by another consumer
 // to restore that state, so it can resume consumption.

examples/cooperative_consumer_example/cooperative_consumer_example.go

@@ -1,8 +1,3 @@
-// Example high-level Apache Kafka consumer using the
-// cooperative incremental rebalancing protocol which allows
-// seamless reassignment of partitions to other group members.
-package main
-
 /**
  * Copyright 2020 Confluent Inc.
  *
@@ -19,6 +14,11 @@ package main
  * limitations under the License.
  */
 
+// Example high-level Apache Kafka consumer using the
+// cooperative incremental rebalancing protocol which allows
+// seamless reassignment of partitions to other group members.
+package main
+
 import (
 	"fmt"
 	"os"

examples/go-kafkacat/go-kafkacat.go

@@ -1,6 +1,3 @@
-// Example kafkacat clone written in Golang
-package main
-
 /**
  * Copyright 2016 Confluent Inc.
  *
@@ -17,15 +14,19 @@ package main
  * limitations under the License.
  */
 
+// Example kafkacat clone written in Golang
+package main
+
 import (
 	"bufio"
 	"fmt"
-	"github.com/alecthomas/kingpin"
-	"github.com/confluentinc/confluent-kafka-go/kafka"
 	"os"
 	"os/signal"
 	"strings"
 	"syscall"
+
+	"github.com/alecthomas/kingpin"
+	"github.com/confluentinc/confluent-kafka-go/kafka"
 )
 
 var (

examples/idempotent_producer_example/idempotent_producer_example.go

@@ -1,16 +1,3 @@
-// Idempotent Producer example.
-//
-// The idempotent producer provides strict ordering and
-// exactly-once producing guarantees.
-//
-// From the application developer's perspective, the only difference
-// from a standard producer is the enabling of the feature by setting
-// the `enable.idempotence` configuration property to true, and
-// handling fatal errors (Error.IsFatal()) which are raised when the
-// idempotent guarantees can't be satisfied.
-
-package main
-
 /**
  * Copyright 2019 Confluent Inc.
  *
@@ -27,6 +14,19 @@ package main
  * limitations under the License.
  */
 
+// Idempotent Producer example.
+//
+// The idempotent producer provides strict ordering and
+// exactly-once producing guarantees.
+//
+// From the application developer's perspective, the only difference
+// from a standard producer is the enabling of the feature by setting
+// the `enable.idempotence` configuration property to true, and
+// handling fatal errors (Error.IsFatal()) which are raised when the
+// idempotent guarantees can't be satisfied.
+
+package main
+
 import (
 	"fmt"
 	"os"

examples/json_consumer_example/json_consumer_example.go

@@ -1,6 +1,3 @@
-// Example function-based high-level Apache Kafka consumer
-package main
-
 /**
  * Copyright 2022 Confluent Inc.
  *
@@ -17,6 +14,9 @@ package main
  * limitations under the License.
  */
 
+// Example function-based high-level Apache Kafka consumer
+package main
+
 // consumer_example implements a consumer using the non-channel Poll() API
 // to retrieve messages and events.
 

examples/json_producer_example/json_producer_example.go

@@ -1,6 +1,3 @@
-// Example function-based Apache Kafka producer
-package main
-
 /**
  * Copyright 2022 Confluent Inc.
  *
@@ -17,6 +14,9 @@ package main
  * limitations under the License.
  */
 
+// Example function-based Apache Kafka producer
+package main
+
 import (
 	"fmt"
 	"os"

examples/legacy/consumer_channel_example/consumer_channel_example.go

@@ -1,6 +1,3 @@
-// Example channel-based high-level Apache Kafka consumer
-package main
-
 /**
  * Copyright 2016 Confluent Inc.
  *
@@ -17,6 +14,9 @@ package main
  * limitations under the License.
  */
 
+// Example channel-based high-level Apache Kafka consumer
+package main
+
 import (
 	"fmt"
 	"os"

examples/legacy/producer_channel_example/producer_channel_example.go

@@ -1,6 +1,3 @@
-// Example channel-based Apache Kafka producer
-package main
-
 /**
  * Copyright 2016 Confluent Inc.
  *
@@ -17,6 +14,9 @@ package main
  * limitations under the License.
  */
 
+// Example channel-based Apache Kafka producer
+package main
+
 import (
 	"fmt"
 	"os"

examples/library-version/library-version.go

@@ -21,11 +21,11 @@ package main
 
 import (
 	"fmt"
+
 	"github.com/confluentinc/confluent-kafka-go/kafka"
 )
 
-
-func main () {
+func main() {
 	vnum, vstr := kafka.LibraryVersion()
 	fmt.Printf("LibraryVersion: %s (0x%x)\n", vstr, vnum)
 	fmt.Printf("LinkInfo:       %s\n", kafka.LibrdkafkaLinkInfo)