From 43046d3feb287036a0b35cc7adf603afc62498e3 Mon Sep 17 00:00:00 2001 From: Rodrigo Arguello Date: Thu, 9 Jan 2025 14:47:11 +0100 Subject: [PATCH] contrib/IBM/sarama.v1: remove commented code --- contrib/IBM/sarama.v1/sarama_test.go | 7 ------- 1 file changed, 7 deletions(-) diff --git a/contrib/IBM/sarama.v1/sarama_test.go b/contrib/IBM/sarama.v1/sarama_test.go index 8855e2e267..8ad6cb05c2 100644 --- a/contrib/IBM/sarama.v1/sarama_test.go +++ b/contrib/IBM/sarama.v1/sarama_test.go @@ -164,13 +164,6 @@ func assertDSMConsumerPathway(t *testing.T, topic, groupID string, msg *sarama.C if withProducer { ctx, _ = tracer.SetDataStreamsCheckpoint(context.Background(), "direction:out", "topic:"+testTopic, "type:kafka") } - - //ctx, _ := tracer.SetDataStreamsCheckpointWithParams( - // datastreams.ExtractFromBase64Carrier(context.Background(), carrier), - // options.CheckpointParams{PayloadSize: getConsumerMsgSize(msg)}, - // edgeTags..., - //) - ctx, _ = tracer.SetDataStreamsCheckpoint(ctx, edgeTags...) want, _ := datastreams.PathwayFromContext(ctx)