[exporter/awskinesisexporter] add raw encode

exporter/awskinesisexporter/internal/batch/encode.go

@@ -52,6 +52,8 @@ func NewEncoder(named string, batchOptions ...Option) (Encoder, error) {
 		bm.logsMarshaller = &plog.JSONMarshaler{}
 		bm.metricsMarshaller = &pmetric.JSONMarshaler{}
 		bm.tracesMarshaller = &ptrace.JSONMarshaler{}
+	case "raw":
+		bm.logsMarshaller = &rawMarshaler{}
 	case "jaeger_proto":
 		// Jaeger encoding is a special case
 		// since the internal libraries offer no means of ptrace.TraceMarshaller.

exporter/awskinesisexporter/internal/batch/raw_marshaler.go

@@ -0,0 +1,28 @@
+// Copyright The OpenTelemetry Authors
+// SPDX-License-Identifier: Apache-2.0
+
+package batch // import "github.com/open-telemetry/opentelemetry-collector-contrib/exporter/awskinesisexporter/internal/batch"
+
+import (
+	"bytes"
+
+	"go.opentelemetry.io/collector/pdata/plog"
+)
+
+type rawMarshaler struct{}
+
+// TODO: implement this func, raw all or raw specific attribute
+func (*rawMarshaler) MarshalLogs(ld plog.Logs) ([]byte, error) {
+	buf := bytes.Buffer{}
+	return buf.Bytes(), nil
+}
+
+var _ plog.Unmarshaler = (*rawUnmarshaler)(nil)
+
+type rawUnmarshaler struct{}
+
+// TODO: Implement this func
+func (*rawUnmarshaler) UnmarshalLogs(buf []byte) (plog.Logs, error) {
+	ld := plog.NewLogs()
+	return ld, nil
+}