fix

Author: Watson1978

lib/fluent/plugin/otlp/request.rb

@@ -19,7 +19,7 @@ def initialize(body)
     end
 
     def body
-      @request.class.encode(@request)
+      @request.to_proto
     end
 
     def record
@@ -38,7 +38,7 @@ def initialize(body)
     end
 
     def body
-      @request.class.encode(@request)
+      @request.to_proto
     end
 
     def record
@@ -57,7 +57,7 @@ def initialize(body)
     end
 
     def body
-      @request.class.encode(@request)
+      @request.to_proto
     end
 
     def record

lib/fluent/plugin/otlp/response.rb

@@ -35,7 +35,7 @@ def initialize(rejected: 0, error: "")
 
     def body(type:)
       if type == :protobuf
-        @response.class.encode(@response)
+        @response.to_proto
       else
         @response.to_json
       end
@@ -58,7 +58,7 @@ def initialize(rejected: 0, error: "")
 
     def body(type:)
       if type == :protobuf
-        @response.class.encode(@response)
+        @response.to_proto
       else
         @response.to_json
       end
@@ -81,7 +81,7 @@ def initialize(rejected: 0, error: "")
 
     def body(type:)
       if type == :protobuf
-        @response.class.encode(@response)
+        @response.to_proto
       else
         @response.to_json
       end