Kafka agent cannot link the producer and consumer trace when use auto-instrumentation java agent.

[sweetxiaodai]

Please see the issue in attached image.

I will also attach my consumer code here. Just copy from spring apache kafka exmaples.

@SpringBootApplication
public class ConsumerApplication {

	public static void main(String[] args) {
		SpringApplication.run(ConsumerApplication.class, args);
	}
	@Bean
	public NewTopic topic() {
		return TopicBuilder.name("topic1")
				.partitions(10)
				.replicas(1)
				.build();
	}

	@KafkaListener(id = "myId", topics = "topic1")
	public void listen(String in) {
		System.out.println(in);
	}
}

[ppatierno]

I would close this issue and continue the discussion on open-telemetry/opentelemetry.io#1781