amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/KinesisDataFetcher.java [563:569]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
				KinesisDeserializationSchema<T> shardDeserializationSchema = getClonedDeserializationSchema();
				shardDeserializationSchema.open(() -> consumerMetricGroup
						.addGroup("subtaskId", String.valueOf(indexOfThisConsumerSubtask))
						.addGroup("shardId", streamShardHandle.getShard().getShardId())
						.addGroup("user"));
				shardConsumersExecutor.submit(
						createShardConsumer(
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/internals/KinesisDataFetcher.java [672:678]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
				KinesisDeserializationSchema<T> shardDeserializationSchema = getClonedDeserializationSchema();
				shardDeserializationSchema.open(() -> consumerMetricGroup
						.addGroup("subtaskId", String.valueOf(indexOfThisConsumerSubtask))
						.addGroup("shardId", streamShardHandle.getShard().getShardId())
						.addGroup("user"));
				shardConsumersExecutor.submit(
						createShardConsumer(
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -