kinesis-lib/src/main/java/com/streamsets/pipeline/stage/origin/kinesis/StreamSetsRecordProcessor.java
@Override
  public void initialize(InitializationInput initializationInput) {
    shardId = initializationInput.getShardId();
    if (LOG.isDebugEnabled()) {
      LOG.debug("Initializing record processor at: {}", initializationInput.getExtendedSequenceNumber().toString());
      LOG.debug("Initializing record processor for shard: {}", shardId);
    }
  }
@Override
  public void initialize(InitializationInput initializationInput) {
    shardId = initializationInput.getShardId();
    if (LOG.isDebugEnabled()) {
      LOG.debug("Initializing record processor at: {}", initializationInput.getExtendedSequenceNumber().toString());
      LOG.debug("Initializing record processor for shard: {}", shardId);
    }
  }
{@inheritDoc}