Merge pull request #30 from easyops-cn/chj/kafka_max_message

feat(opentelemetry-collector): kafka-exporter增加maxmessagebytes参数 refs…

exporter/kafkaexporter/config.go

@@ -35,6 +35,10 @@ type Config struct {
 	// The name of the kafka topic to export to (default otlp_spans for traces, otlp_metrics for metrics)
 	Topic string `mapstructure:"topic"`
 
+	// The maximum permitted size of a message (defaults to 1000000). Should be
+	// set equal to or smaller than the broker's `message.max.bytes`.
+	MaxMessageBytes int `mapstructure:"max_message_bytes"`
+
 	// message key in order to partition
 	MessageKey string `mapstructure:"message_key"`
 

exporter/kafkaexporter/kafka_exporter.go

@@ -135,6 +135,9 @@ func newSaramaProducer(config Config) (sarama.SyncProducer, error) {
 		}
 		c.Version = version
 	}
+	if config.MaxMessageBytes > 0 {
+		c.Producer.MaxMessageBytes = config.MaxMessageBytes
+	}
 	if err := ConfigureAuthentication(config.Authentication, c); err != nil {
 		return nil, err
 	}