protobuf: replace magic profiling literals with DefaultProfilingOptions

Author: mmatczuk

internal/impl/confluent/serde_protobuf.go

@@ -85,10 +85,7 @@ func (s *schemaRegistryDecoder) getProtobufDecoder(
 		defer mu.Unlock()
 		if msgDesc.FullName() != cachedMessageName {
 			cachedMessageName = msgDesc.FullName()
-			cachedDecoder = common.NewHyperPbDecoder(msgDesc, common.ProfilingOptions{
-				Rate:              0.01,
-				RecompileInterval: 100_000,
-			})
+			cachedDecoder = common.NewHyperPbDecoder(msgDesc, common.DefaultProfilingOptions)
 		}
 		return cachedDecoder
 	}

internal/impl/protobuf/common/decode_common.go

@@ -32,3 +32,10 @@ type ProfilingOptions struct {
 	Rate              float64
 	RecompileInterval int64
 }
+
+// DefaultProfilingOptions are the standard profiling settings used across all
+// hyperpb decoder call sites.
+var DefaultProfilingOptions = ProfilingOptions{
+	Rate:              0.01,
+	RecompileInterval: 100_000,
+}

internal/impl/protobuf/processor_protobuf.go

@@ -329,12 +329,7 @@ func newProtobufToJSONOperator(
 	if err != nil {
 		return nil, fmt.Errorf("unable to find protobuf type %q: %w", msg, err)
 	}
-	decoder := common.NewHyperPbDecoder(
-		msgType.Descriptor(),
-		common.ProfilingOptions{
-			Rate:              0.01,
-			RecompileInterval: 100_000,
-		})
+	decoder := common.NewHyperPbDecoder(msgType.Descriptor(), common.DefaultProfilingOptions)
 	opts.Resolver = types
 	return func(part *service.Message) error {
 		partBytes, err := part.AsBytes()
@@ -403,12 +398,7 @@ func newProtobufToJSONBSROperator(
 	if err != nil {
 		return nil, fmt.Errorf("unable to find message '%v' definition: %w", msg, err)
 	}
-	decoder := common.NewHyperPbDecoder(
-		d.Descriptor(),
-		common.ProfilingOptions{
-			Rate:              0.01,
-			RecompileInterval: 100_000,
-		})
+	decoder := common.NewHyperPbDecoder(d.Descriptor(), common.DefaultProfilingOptions)
 	opts.Resolver = multiModuleWatcher
 	return func(part *service.Message) error {
 		partBytes, err := part.AsBytes()