Python Agent: Spans is not set into the same trace

[WinterWaterWarm]

When I hang up a consumer program

i think when the consumer consumes the data, a Trace containing two Spans(kafka+redis) will be generated
But in fact, it generates two separate Trace，like this:

{
    "isSizeLimited": false,
    "service": "email",
    "serviceInstance": "3f6b4080699511ed84ee38baf811c60e",
    "spans": [
        {
            "SegmentReference": null,
            "componentId": 41,
            "endTime": 1669032725578,
            "isError": false,
            "logs": null,
            "operationName": "Kafka/pytsw/Consumer/local-email-creator",
            "parentSpanId": -1,
            "peer": "",
            "skipAnalysis": false,
            "spanId": 0,
            "spanLayer": "MQ",
            "spanType": "Entry",
            "startTime": 1669032725578,
            "tags": {
                "mq.broker": "localhost:9092",
                "mq.topic": "pytsw"
            }
        }
    ],
    "traceId": "b6c55cda699511edb49238baf811c60e",
    "traceSegmentId": "b6c55cd8699511edb01538baf811c60e"
}
{
    "isSizeLimited": false,
    "service": "email",
    "serviceInstance": "3f6b4080699511ed84ee38baf811c60e",
    "spans": [
        {
            "SegmentReference": null,
            "componentId": 7,
            "endTime": 1669032725604,
            "isError": false,
            "logs": null,
            "operationName": "Redis/GET",
            "parentSpanId": -1,
            "peer": "10.11.24.124:6379",
            "skipAnalysis": false,
            "spanId": 0,
            "spanLayer": "Cache",
            "spanType": "Exit",
            "startTime": 1669032725604,
            "tags": {
                "db.instance": "0",
                "db.statement": "GET",
                "db.type": "Redis"
            }
        }
    ],
    "traceId": "b6c95c41699511ed812d38baf811c60e",
    "traceSegmentId": "b6c95c40699511edb16838baf811c60e"
}

Is this a bug, or do I misunderstand it?