Logging shardId of the consumed records in KCL2.0

[Udhay707]

public class KinesisRecordProcessor implements ShardRecordProcessor {

private String shardId;


@Override
public void initialize(InitializationInput initializationInput) {
	log.info("Starting to consume from shard: " + initializationInput.shardId());
	this.shardId = initializationInput.shardId();
}

@Override
public void processRecords(ProcessRecordsInput processRecordsInput) {
log.info("ShardId: {}", this.shardId);
}

Using the abovt approach, I am unable to get the actual shardId from which the record is processed, I have also tried with MDC, still no luck. Is there a way to accurately log the shardId ?