diff --git a/contrib/segmentio/kafka.go.v0/kafka.go b/contrib/segmentio/kafka.go.v0/kafka.go
index ff7b81edb0..458bb40675 100644
--- a/contrib/segmentio/kafka.go.v0/kafka.go
+++ b/contrib/segmentio/kafka.go.v0/kafka.go
@@ -127,9 +127,13 @@ type Writer struct {
 func (w *Writer) startSpan(ctx context.Context, msg *kafka.Message) ddtrace.Span {
 	opts := []tracer.StartSpanOption{
 		tracer.ServiceName(w.cfg.producerServiceName),
-		tracer.ResourceName("Produce Topic " + w.Writer.Topic),
 		tracer.SpanType(ext.SpanTypeMessageProducer),
 	}
+	if w.Writer.Topic != "" {
+		opts = append(opts, tracer.ResourceName("Produce Topic "+w.Writer.Topic))
+	} else {
+		opts = append(opts, tracer.ResourceName("Produce Topic "+msg.Topic))
+	}
 	if !math.IsNaN(w.cfg.analyticsRate) {
 		opts = append(opts, tracer.Tag(ext.EventSampleRate, w.cfg.analyticsRate))
 	}