diff --git a/pkg/apis/proto/source/v1/sourcemock/sourcemock.go b/pkg/apis/proto/source/v1/sourcemock/sourcemock.go
index cc3674f9..b868dc82 100644
--- a/pkg/apis/proto/source/v1/sourcemock/sourcemock.go
+++ b/pkg/apis/proto/source/v1/sourcemock/sourcemock.go
@@ -298,21 +298,6 @@ func (m *MockSource_AckFnClient) EXPECT() *MockSource_AckFnClientMockRecorder {
 	return m.recorder
 }
 
-// CloseAndRecv mocks base method.
-func (m *MockSource_AckFnClient) CloseAndRecv() (*v1.AckResponse, error) {
-	m.ctrl.T.Helper()
-	ret := m.ctrl.Call(m, "CloseAndRecv")
-	ret0, _ := ret[0].(*v1.AckResponse)
-	ret1, _ := ret[1].(error)
-	return ret0, ret1
-}
-
-// CloseAndRecv indicates an expected call of CloseAndRecv.
-func (mr *MockSource_AckFnClientMockRecorder) CloseAndRecv() *gomock.Call {
-	mr.mock.ctrl.T.Helper()
-	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CloseAndRecv", reflect.TypeOf((*MockSource_AckFnClient)(nil).CloseAndRecv))
-}
-
 // CloseSend mocks base method.
 func (m *MockSource_AckFnClient) CloseSend() error {
 	m.ctrl.T.Helper()
@@ -356,6 +341,21 @@ func (mr *MockSource_AckFnClientMockRecorder) Header() *gomock.Call {
 	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Header", reflect.TypeOf((*MockSource_AckFnClient)(nil).Header))
 }
 
+// Recv mocks base method.
+func (m *MockSource_AckFnClient) Recv() (*v1.AckResponse, error) {
+	m.ctrl.T.Helper()
+	ret := m.ctrl.Call(m, "Recv")
+	ret0, _ := ret[0].(*v1.AckResponse)
+	ret1, _ := ret[1].(error)
+	return ret0, ret1
+}
+
+// Recv indicates an expected call of Recv.
+func (mr *MockSource_AckFnClientMockRecorder) Recv() *gomock.Call {
+	mr.mock.ctrl.T.Helper()
+	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Recv", reflect.TypeOf((*MockSource_AckFnClient)(nil).Recv))
+}
+
 // RecvMsg mocks base method.
 func (m *MockSource_AckFnClient) RecvMsg(arg0 interface{}) error {
 	m.ctrl.T.Helper()