diff --git a/Makefile b/Makefile
index 7bf5f73be..23e5b5977 100644
--- a/Makefile
+++ b/Makefile
@@ -114,6 +114,7 @@ $(PROTO_PBS): $(PROTO_SRCS)
 		$(PROTOC) $(PROTO_INCS) \
 		--gogo_out=plugins=grpc,Mgoogle/protobuf/empty.proto=github.com/gogo/protobuf/types,Mgoogle/protobuf/any.proto=github.com/gogo/protobuf/types,Mgoogle/protobuf/duration.proto=github.com/gogo/protobuf/types,paths=source_relative:. $$src ; \
 	done
+	git apply -v proto/patches/*.patch
 
 proto-check:
 	$(MAKE) proto
diff --git a/proto/patches/snpb_replicator.patch b/proto/patches/snpb_replicator.patch
new file mode 100644
index 000000000..a87409c4f
--- /dev/null
+++ b/proto/patches/snpb_replicator.patch
@@ -0,0 +1,545 @@
+diff --git a/proto/snpb/replicator.pb.go b/proto/snpb/replicator.pb.go
+index 139a31eb..e5105c63 100644
+--- a/proto/snpb/replicator.pb.go
++++ b/proto/snpb/replicator.pb.go
+@@ -10,6 +10,7 @@ import (
+ 	io "io"
+ 	math "math"
+ 	math_bits "math/bits"
++	"slices"
+ 	strconv "strconv"
+ 
+ 	_ "github.com/gogo/protobuf/gogoproto"
+@@ -24,9 +25,11 @@ import (
+ )
+ 
+ // Reference imports to suppress errors if they are not otherwise used.
+-var _ = proto.Marshal
+-var _ = fmt.Errorf
+-var _ = math.Inf
++var (
++	_ = proto.Marshal
++	_ = fmt.Errorf
++	_ = math.Inf
++)
+ 
+ // This is a compile-time assertion to ensure that this generated file
+ // is compatible with the proto package it is being compiled against.
+@@ -80,9 +83,11 @@ func (*ReplicateRequest) ProtoMessage()    {}
+ func (*ReplicateRequest) Descriptor() ([]byte, []int) {
+ 	return fileDescriptor_85705cb817486b63, []int{0}
+ }
++
+ func (m *ReplicateRequest) XXX_Unmarshal(b []byte) error {
+ 	return m.Unmarshal(b)
+ }
++
+ func (m *ReplicateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
+ 	if deterministic {
+ 		return xxx_messageInfo_ReplicateRequest.Marshal(b, m, deterministic)
+@@ -95,12 +100,15 @@ func (m *ReplicateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, er
+ 		return b[:n], nil
+ 	}
+ }
++
+ func (m *ReplicateRequest) XXX_Merge(src proto.Message) {
+ 	xxx_messageInfo_ReplicateRequest.Merge(m, src)
+ }
++
+ func (m *ReplicateRequest) XXX_Size() int {
+ 	return m.ProtoSize()
+ }
++
+ func (m *ReplicateRequest) XXX_DiscardUnknown() {
+ 	xxx_messageInfo_ReplicateRequest.DiscardUnknown(m)
+ }
+@@ -135,8 +143,7 @@ func (m *ReplicateRequest) GetData() [][]byte {
+ 	return nil
+ }
+ 
+-type ReplicateResponse struct {
+-}
++type ReplicateResponse struct{}
+ 
+ func (m *ReplicateResponse) Reset()         { *m = ReplicateResponse{} }
+ func (m *ReplicateResponse) String() string { return proto.CompactTextString(m) }
+@@ -144,9 +151,11 @@ func (*ReplicateResponse) ProtoMessage()    {}
+ func (*ReplicateResponse) Descriptor() ([]byte, []int) {
+ 	return fileDescriptor_85705cb817486b63, []int{1}
+ }
++
+ func (m *ReplicateResponse) XXX_Unmarshal(b []byte) error {
+ 	return m.Unmarshal(b)
+ }
++
+ func (m *ReplicateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
+ 	if deterministic {
+ 		return xxx_messageInfo_ReplicateResponse.Marshal(b, m, deterministic)
+@@ -159,12 +168,15 @@ func (m *ReplicateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, e
+ 		return b[:n], nil
+ 	}
+ }
++
+ func (m *ReplicateResponse) XXX_Merge(src proto.Message) {
+ 	xxx_messageInfo_ReplicateResponse.Merge(m, src)
+ }
++
+ func (m *ReplicateResponse) XXX_Size() int {
+ 	return m.ProtoSize()
+ }
++
+ func (m *ReplicateResponse) XXX_DiscardUnknown() {
+ 	xxx_messageInfo_ReplicateResponse.DiscardUnknown(m)
+ }
+@@ -182,9 +194,11 @@ func (*SyncPosition) ProtoMessage()    {}
+ func (*SyncPosition) Descriptor() ([]byte, []int) {
+ 	return fileDescriptor_85705cb817486b63, []int{2}
+ }
++
+ func (m *SyncPosition) XXX_Unmarshal(b []byte) error {
+ 	return m.Unmarshal(b)
+ }
++
+ func (m *SyncPosition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
+ 	if deterministic {
+ 		return xxx_messageInfo_SyncPosition.Marshal(b, m, deterministic)
+@@ -197,12 +211,15 @@ func (m *SyncPosition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
+ 		return b[:n], nil
+ 	}
+ }
++
+ func (m *SyncPosition) XXX_Merge(src proto.Message) {
+ 	xxx_messageInfo_SyncPosition.Merge(m, src)
+ }
++
+ func (m *SyncPosition) XXX_Size() int {
+ 	return m.ProtoSize()
+ }
++
+ func (m *SyncPosition) XXX_DiscardUnknown() {
+ 	xxx_messageInfo_SyncPosition.DiscardUnknown(m)
+ }
+@@ -239,9 +256,11 @@ func (*SyncRange) ProtoMessage()    {}
+ func (*SyncRange) Descriptor() ([]byte, []int) {
+ 	return fileDescriptor_85705cb817486b63, []int{3}
+ }
++
+ func (m *SyncRange) XXX_Unmarshal(b []byte) error {
+ 	return m.Unmarshal(b)
+ }
++
+ func (m *SyncRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
+ 	if deterministic {
+ 		return xxx_messageInfo_SyncRange.Marshal(b, m, deterministic)
+@@ -254,12 +273,15 @@ func (m *SyncRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
+ 		return b[:n], nil
+ 	}
+ }
++
+ func (m *SyncRange) XXX_Merge(src proto.Message) {
+ 	xxx_messageInfo_SyncRange.Merge(m, src)
+ }
++
+ func (m *SyncRange) XXX_Size() int {
+ 	return m.ProtoSize()
+ }
++
+ func (m *SyncRange) XXX_DiscardUnknown() {
+ 	xxx_messageInfo_SyncRange.DiscardUnknown(m)
+ }
+@@ -305,9 +327,11 @@ func (*SyncInitRequest) ProtoMessage()    {}
+ func (*SyncInitRequest) Descriptor() ([]byte, []int) {
+ 	return fileDescriptor_85705cb817486b63, []int{4}
+ }
++
+ func (m *SyncInitRequest) XXX_Unmarshal(b []byte) error {
+ 	return m.Unmarshal(b)
+ }
++
+ func (m *SyncInitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
+ 	if deterministic {
+ 		return xxx_messageInfo_SyncInitRequest.Marshal(b, m, deterministic)
+@@ -320,12 +344,15 @@ func (m *SyncInitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, err
+ 		return b[:n], nil
+ 	}
+ }
++
+ func (m *SyncInitRequest) XXX_Merge(src proto.Message) {
+ 	xxx_messageInfo_SyncInitRequest.Merge(m, src)
+ }
++
+ func (m *SyncInitRequest) XXX_Size() int {
+ 	return m.ProtoSize()
+ }
++
+ func (m *SyncInitRequest) XXX_DiscardUnknown() {
+ 	xxx_messageInfo_SyncInitRequest.DiscardUnknown(m)
+ }
+@@ -381,9 +408,11 @@ func (*SyncInitResponse) ProtoMessage()    {}
+ func (*SyncInitResponse) Descriptor() ([]byte, []int) {
+ 	return fileDescriptor_85705cb817486b63, []int{5}
+ }
++
+ func (m *SyncInitResponse) XXX_Unmarshal(b []byte) error {
+ 	return m.Unmarshal(b)
+ }
++
+ func (m *SyncInitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
+ 	if deterministic {
+ 		return xxx_messageInfo_SyncInitResponse.Marshal(b, m, deterministic)
+@@ -396,12 +425,15 @@ func (m *SyncInitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, er
+ 		return b[:n], nil
+ 	}
+ }
++
+ func (m *SyncInitResponse) XXX_Merge(src proto.Message) {
+ 	xxx_messageInfo_SyncInitResponse.Merge(m, src)
+ }
++
+ func (m *SyncInitResponse) XXX_Size() int {
+ 	return m.ProtoSize()
+ }
++
+ func (m *SyncInitResponse) XXX_DiscardUnknown() {
+ 	xxx_messageInfo_SyncInitResponse.DiscardUnknown(m)
+ }
+@@ -428,9 +460,11 @@ func (*SyncStatus) ProtoMessage()    {}
+ func (*SyncStatus) Descriptor() ([]byte, []int) {
+ 	return fileDescriptor_85705cb817486b63, []int{6}
+ }
++
+ func (m *SyncStatus) XXX_Unmarshal(b []byte) error {
+ 	return m.Unmarshal(b)
+ }
++
+ func (m *SyncStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
+ 	if deterministic {
+ 		return xxx_messageInfo_SyncStatus.Marshal(b, m, deterministic)
+@@ -443,12 +477,15 @@ func (m *SyncStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
+ 		return b[:n], nil
+ 	}
+ }
++
+ func (m *SyncStatus) XXX_Merge(src proto.Message) {
+ 	xxx_messageInfo_SyncStatus.Merge(m, src)
+ }
++
+ func (m *SyncStatus) XXX_Size() int {
+ 	return m.ProtoSize()
+ }
++
+ func (m *SyncStatus) XXX_DiscardUnknown() {
+ 	xxx_messageInfo_SyncStatus.DiscardUnknown(m)
+ }
+@@ -494,9 +531,11 @@ func (*SyncPayload) ProtoMessage()    {}
+ func (*SyncPayload) Descriptor() ([]byte, []int) {
+ 	return fileDescriptor_85705cb817486b63, []int{7}
+ }
++
+ func (m *SyncPayload) XXX_Unmarshal(b []byte) error {
+ 	return m.Unmarshal(b)
+ }
++
+ func (m *SyncPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
+ 	if deterministic {
+ 		return xxx_messageInfo_SyncPayload.Marshal(b, m, deterministic)
+@@ -509,12 +548,15 @@ func (m *SyncPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
+ 		return b[:n], nil
+ 	}
+ }
++
+ func (m *SyncPayload) XXX_Merge(src proto.Message) {
+ 	xxx_messageInfo_SyncPayload.Merge(m, src)
+ }
++
+ func (m *SyncPayload) XXX_Size() int {
+ 	return m.ProtoSize()
+ }
++
+ func (m *SyncPayload) XXX_DiscardUnknown() {
+ 	xxx_messageInfo_SyncPayload.DiscardUnknown(m)
+ }
+@@ -548,9 +590,11 @@ func (*SyncReplicateRequest) ProtoMessage()    {}
+ func (*SyncReplicateRequest) Descriptor() ([]byte, []int) {
+ 	return fileDescriptor_85705cb817486b63, []int{8}
+ }
++
+ func (m *SyncReplicateRequest) XXX_Unmarshal(b []byte) error {
+ 	return m.Unmarshal(b)
+ }
++
+ func (m *SyncReplicateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
+ 	if deterministic {
+ 		return xxx_messageInfo_SyncReplicateRequest.Marshal(b, m, deterministic)
+@@ -563,12 +607,15 @@ func (m *SyncReplicateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte
+ 		return b[:n], nil
+ 	}
+ }
++
+ func (m *SyncReplicateRequest) XXX_Merge(src proto.Message) {
+ 	xxx_messageInfo_SyncReplicateRequest.Merge(m, src)
+ }
++
+ func (m *SyncReplicateRequest) XXX_Size() int {
+ 	return m.ProtoSize()
+ }
++
+ func (m *SyncReplicateRequest) XXX_DiscardUnknown() {
+ 	xxx_messageInfo_SyncReplicateRequest.DiscardUnknown(m)
+ }
+@@ -613,9 +660,11 @@ func (*SyncReplicateResponse) ProtoMessage()    {}
+ func (*SyncReplicateResponse) Descriptor() ([]byte, []int) {
+ 	return fileDescriptor_85705cb817486b63, []int{9}
+ }
++
+ func (m *SyncReplicateResponse) XXX_Unmarshal(b []byte) error {
+ 	return m.Unmarshal(b)
+ }
++
+ func (m *SyncReplicateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
+ 	if deterministic {
+ 		return xxx_messageInfo_SyncReplicateResponse.Marshal(b, m, deterministic)
+@@ -628,12 +677,15 @@ func (m *SyncReplicateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byt
+ 		return b[:n], nil
+ 	}
+ }
++
+ func (m *SyncReplicateResponse) XXX_Merge(src proto.Message) {
+ 	xxx_messageInfo_SyncReplicateResponse.Merge(m, src)
+ }
++
+ func (m *SyncReplicateResponse) XXX_Size() int {
+ 	return m.ProtoSize()
+ }
++
+ func (m *SyncReplicateResponse) XXX_DiscardUnknown() {
+ 	xxx_messageInfo_SyncReplicateResponse.DiscardUnknown(m)
+ }
+@@ -738,6 +790,7 @@ func (x SyncState) String() string {
+ 	}
+ 	return strconv.Itoa(int(x))
+ }
++
+ func (this *ReplicateRequest) Equal(that interface{}) bool {
+ 	if that == nil {
+ 		return this == nil
+@@ -781,6 +834,7 @@ func (this *ReplicateRequest) Equal(that interface{}) bool {
+ 	}
+ 	return true
+ }
++
+ func (this *SyncPosition) Equal(that interface{}) bool {
+ 	if that == nil {
+ 		return this == nil
+@@ -810,8 +864,10 @@ func (this *SyncPosition) Equal(that interface{}) bool {
+ }
+ 
+ // Reference imports to suppress errors if they are not otherwise used.
+-var _ context.Context
+-var _ grpc.ClientConn
++var (
++	_ context.Context
++	_ grpc.ClientConn
++)
+ 
+ // This is a compile-time assertion to ensure that this generated file
+ // is compatible with the grpc package it is being compiled against.
+@@ -1022,18 +1078,20 @@ type ReplicatorServer interface {
+ }
+ 
+ // UnimplementedReplicatorServer can be embedded to have forward compatible implementations.
+-type UnimplementedReplicatorServer struct {
+-}
++type UnimplementedReplicatorServer struct{}
+ 
+ func (*UnimplementedReplicatorServer) Replicate(srv Replicator_ReplicateServer) error {
+ 	return status.Errorf(codes.Unimplemented, "method Replicate not implemented")
+ }
++
+ func (*UnimplementedReplicatorServer) SyncInit(ctx context.Context, req *SyncInitRequest) (*SyncInitResponse, error) {
+ 	return nil, status.Errorf(codes.Unimplemented, "method SyncInit not implemented")
+ }
++
+ func (*UnimplementedReplicatorServer) SyncReplicate(ctx context.Context, req *SyncReplicateRequest) (*SyncReplicateResponse, error) {
+ 	return nil, status.Errorf(codes.Unimplemented, "method SyncReplicate not implemented")
+ }
++
+ func (*UnimplementedReplicatorServer) SyncReplicateStream(srv Replicator_SyncReplicateStreamServer) error {
+ 	return status.Errorf(codes.Unimplemented, "method SyncReplicateStream not implemented")
+ }
+@@ -1612,6 +1670,7 @@ func encodeVarintReplicator(dAtA []byte, offset int, v uint64) int {
+ 	dAtA[offset] = uint8(v)
+ 	return base
+ }
++
+ func NewPopulatedReplicateRequest(r randyReplicator, easy bool) *ReplicateRequest {
+ 	this := &ReplicateRequest{}
+ 	this.TopicID = github_com_kakao_varlog_pkg_types.TopicID(r.Int31())
+@@ -1659,6 +1718,7 @@ func randUTF8RuneReplicator(r randyReplicator) rune {
+ 	}
+ 	return rune(ru + 61)
+ }
++
+ func randStringReplicator(r randyReplicator) string {
+ 	v4 := r.Intn(100)
+ 	tmps := make([]rune, v4)
+@@ -1667,6 +1727,7 @@ func randStringReplicator(r randyReplicator) string {
+ 	}
+ 	return string(tmps)
+ }
++
+ func randUnrecognizedReplicator(r randyReplicator, maxFieldNumber int) (dAtA []byte) {
+ 	l := r.Intn(5)
+ 	for i := 0; i < l; i++ {
+@@ -1679,6 +1740,7 @@ func randUnrecognizedReplicator(r randyReplicator, maxFieldNumber int) (dAtA []b
+ 	}
+ 	return dAtA
+ }
++
+ func randFieldReplicator(dAtA []byte, r randyReplicator, fieldNumber int, wire int) []byte {
+ 	key := uint32(fieldNumber)<<3 | uint32(wire)
+ 	switch wire {
+@@ -1705,6 +1767,7 @@ func randFieldReplicator(dAtA []byte, r randyReplicator, fieldNumber int, wire i
+ 	}
+ 	return dAtA
+ }
++
+ func encodeVarintPopulateReplicator(dAtA []byte, v uint64) []byte {
+ 	for v >= 1<<7 {
+ 		dAtA = append(dAtA, uint8(uint64(v)&0x7f|0x80))
+@@ -1713,6 +1776,7 @@ func encodeVarintPopulateReplicator(dAtA []byte, v uint64) []byte {
+ 	dAtA = append(dAtA, uint8(v))
+ 	return dAtA
+ }
++
+ func (m *ReplicateRequest) ProtoSize() (n int) {
+ 	if m == nil {
+ 		return 0
+@@ -1881,9 +1945,11 @@ func (m *SyncReplicateResponse) ProtoSize() (n int) {
+ func sovReplicator(x uint64) (n int) {
+ 	return (math_bits.Len64(x|1) + 6) / 7
+ }
++
+ func sozReplicator(x uint64) (n int) {
+ 	return sovReplicator(uint64((x << 1) ^ uint64((int64(x) >> 63))))
+ }
++
+ func (this *SyncPayload) GetValue() interface{} {
+ 	if this.CommitContext != nil {
+ 		return this.CommitContext
+@@ -1905,6 +1971,7 @@ func (this *SyncPayload) SetValue(value interface{}) bool {
+ 	}
+ 	return true
+ }
++
+ func (m *ReplicateRequest) Unmarshal(dAtA []byte) error {
+ 	l := len(dAtA)
+ 	iNdEx := 0
+@@ -2025,7 +2092,8 @@ func (m *ReplicateRequest) Unmarshal(dAtA []byte) error {
+ 				}
+ 				elementCount = count
+ 				if elementCount != 0 && len(m.LLSN) == 0 {
+-					m.LLSN = make([]github_com_kakao_varlog_pkg_types.LLSN, 0, elementCount)
++					m.LLSN = slices.Grow(m.LLSN, elementCount)
++					m.LLSN = m.LLSN[:0]
+ 				}
+ 				for iNdEx < postIndex {
+ 					var v github_com_kakao_varlog_pkg_types.LLSN
+@@ -2077,8 +2145,15 @@ func (m *ReplicateRequest) Unmarshal(dAtA []byte) error {
+ 			if postIndex > l {
+ 				return io.ErrUnexpectedEOF
+ 			}
+-			m.Data = append(m.Data, make([]byte, postIndex-iNdEx))
+-			copy(m.Data[len(m.Data)-1], dAtA[iNdEx:postIndex])
++			if len(m.Data) < cap(m.Data) {
++				m.Data = m.Data[:len(m.Data)+1]
++			} else {
++				m.Data = append(m.Data, nil)
++			}
++			lastIndex := len(m.Data) - 1
++			m.Data[lastIndex] = slices.Grow(m.Data[lastIndex], postIndex-iNdEx)
++			m.Data[lastIndex] = m.Data[lastIndex][:postIndex-iNdEx]
++			copy(m.Data[lastIndex], dAtA[iNdEx:postIndex])
+ 			iNdEx = postIndex
+ 		default:
+ 			iNdEx = preIndex
+@@ -2101,6 +2176,7 @@ func (m *ReplicateRequest) Unmarshal(dAtA []byte) error {
+ 	}
+ 	return nil
+ }
++
+ func (m *ReplicateResponse) Unmarshal(dAtA []byte) error {
+ 	l := len(dAtA)
+ 	iNdEx := 0
+@@ -2151,6 +2227,7 @@ func (m *ReplicateResponse) Unmarshal(dAtA []byte) error {
+ 	}
+ 	return nil
+ }
++
+ func (m *SyncPosition) Unmarshal(dAtA []byte) error {
+ 	l := len(dAtA)
+ 	iNdEx := 0
+@@ -2239,6 +2316,7 @@ func (m *SyncPosition) Unmarshal(dAtA []byte) error {
+ 	}
+ 	return nil
+ }
++
+ func (m *SyncRange) Unmarshal(dAtA []byte) error {
+ 	l := len(dAtA)
+ 	iNdEx := 0
+@@ -2327,6 +2405,7 @@ func (m *SyncRange) Unmarshal(dAtA []byte) error {
+ 	}
+ 	return nil
+ }
++
+ func (m *SyncInitRequest) Unmarshal(dAtA []byte) error {
+ 	l := len(dAtA)
+ 	iNdEx := 0
+@@ -2514,6 +2593,7 @@ func (m *SyncInitRequest) Unmarshal(dAtA []byte) error {
+ 	}
+ 	return nil
+ }
++
+ func (m *SyncInitResponse) Unmarshal(dAtA []byte) error {
+ 	l := len(dAtA)
+ 	iNdEx := 0
+@@ -2597,6 +2677,7 @@ func (m *SyncInitResponse) Unmarshal(dAtA []byte) error {
+ 	}
+ 	return nil
+ }
++
+ func (m *SyncStatus) Unmarshal(dAtA []byte) error {
+ 	l := len(dAtA)
+ 	iNdEx := 0
+@@ -2765,6 +2846,7 @@ func (m *SyncStatus) Unmarshal(dAtA []byte) error {
+ 	}
+ 	return nil
+ }
++
+ func (m *SyncPayload) Unmarshal(dAtA []byte) error {
+ 	l := len(dAtA)
+ 	iNdEx := 0
+@@ -2887,6 +2969,7 @@ func (m *SyncPayload) Unmarshal(dAtA []byte) error {
+ 	}
+ 	return nil
+ }
++
+ func (m *SyncReplicateRequest) Unmarshal(dAtA []byte) error {
+ 	l := len(dAtA)
+ 	iNdEx := 0
+@@ -3055,6 +3138,7 @@ func (m *SyncReplicateRequest) Unmarshal(dAtA []byte) error {
+ 	}
+ 	return nil
+ }
++
+ func (m *SyncReplicateResponse) Unmarshal(dAtA []byte) error {
+ 	l := len(dAtA)
+ 	iNdEx := 0
+@@ -3141,6 +3225,7 @@ func (m *SyncReplicateResponse) Unmarshal(dAtA []byte) error {
+ 	}
+ 	return nil
+ }
++
+ func skipReplicator(dAtA []byte) (n int, err error) {
+ 	l := len(dAtA)
+ 	iNdEx := 0