fix make + append

DataDog · Oct 7, 2024 · 704d50a · 704d50a
1 parent e7a15d1
commit 704d50a
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/contrib/segmentio/kafka.go.v0/kafka.go b/contrib/segmentio/kafka.go.v0/kafka.go
@@ -142,7 +142,7 @@ func (w *Writer) WriteMessages(ctx context.Context, msgs ...kafka.Message) error
 
 func tracingMessage(msg *kafka.Message) *tracing.KafkaMessage {
  setHeaders := func(newHeaders []tracing.KafkaHeader) {
- hs := make([]kafka.Header, len(newHeaders))
+ hs := make([]kafka.Header, 0, len(newHeaders))
  for _, h := range newHeaders {
  hs = append(hs, kafka.Header{
  Key: h.Key,
@@ -163,7 +163,7 @@ func tracingMessage(msg *kafka.Message) *tracing.KafkaMessage {
 }
 
 func tracingKafkaHeaders(headers []kafka.Header) []tracing.KafkaHeader {
- hs := make([]tracing.KafkaHeader, len(headers))
+ hs := make([]tracing.KafkaHeader, 0, len(headers))
  for _, h := range headers {
  hs = append(hs, tracing.KafkaHeader{
  Key: h.Key,

diff --git a/contrib/segmentio/kafka.go.v0/kafka_test.go b/contrib/segmentio/kafka.go.v0/kafka_test.go
@@ -121,7 +121,7 @@ func ensureTopicReady() error {
  reader := testReader()
  defer reader.Close()
 
- ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
+ ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
  defer cancel()
 
  var (