-
Notifications
You must be signed in to change notification settings - Fork 485
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 ?
All reactions
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment