From 39780accbfe231124dfdbb18ed8e97c2836b7484 Mon Sep 17 00:00:00 2001 From: Yashash H L Date: Mon, 16 Sep 2024 10:46:18 +0530 Subject: [PATCH] make proto Signed-off-by: Yashash H L --- go.mod | 2 +- go.sum | 4 ++-- pkg/sourcer/examples/simple_source/impl/simple_source.go | 8 +++----- 3 files changed, 6 insertions(+), 8 deletions(-) diff --git a/go.mod b/go.mod index 4a40c1c2..89f343aa 100644 --- a/go.mod +++ b/go.mod @@ -9,7 +9,7 @@ require ( golang.org/x/net v0.29.0 golang.org/x/sync v0.8.0 google.golang.org/grpc v1.66.0 - google.golang.org/grpc/cmd/protoc-gen-go-grpc v1.5.1 + google.golang.org/grpc/cmd/protoc-gen-go-grpc v1.3.0 google.golang.org/protobuf v1.34.2 ) diff --git a/go.sum b/go.sum index 815987bf..d75c5d4e 100644 --- a/go.sum +++ b/go.sum @@ -53,8 +53,8 @@ google.golang.org/genproto/googleapis/rpc v0.0.0-20240903143218-8af14fe29dc1 h1: google.golang.org/genproto/googleapis/rpc v0.0.0-20240903143218-8af14fe29dc1/go.mod h1:UqMtugtsSgubUsoxbuAoiCXvqvErP7Gf0so0mK9tHxU= google.golang.org/grpc v1.66.0 h1:DibZuoBznOxbDQxRINckZcUvnCEvrW9pcWIE2yF9r1c= google.golang.org/grpc v1.66.0/go.mod h1:s3/l6xSSCURdVfAnL+TqCNMyTDAGN6+lZeVxnZR128Y= -google.golang.org/grpc/cmd/protoc-gen-go-grpc v1.5.1 h1:F29+wU6Ee6qgu9TddPgooOdaqsxTMunOoj8KA5yuS5A= -google.golang.org/grpc/cmd/protoc-gen-go-grpc v1.5.1/go.mod h1:5KF+wpkbTSbGcR9zteSqZV6fqFOWBl4Yde8En8MryZA= +google.golang.org/grpc/cmd/protoc-gen-go-grpc v1.3.0 h1:rNBFJjBCOgVr9pWD7rs/knKL4FRTKgpZmsRfV214zcA= +google.golang.org/grpc/cmd/protoc-gen-go-grpc v1.3.0/go.mod h1:Dk1tviKTvMCz5tvh7t+fh94dhmQVHuCt2OzJB3CTW9Y= google.golang.org/protobuf v1.34.2 h1:6xV6lTsCfpGD21XK49h7MhtcApnLqkfYgPcdHftf6hg= google.golang.org/protobuf v1.34.2/go.mod h1:qYOHts0dSfpeUzUFpOMr/WGzszTmLH+DiWniOlNbLDw= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= diff --git a/pkg/sourcer/examples/simple_source/impl/simple_source.go b/pkg/sourcer/examples/simple_source/impl/simple_source.go index 9409fe25..87ec9dcb 100644 --- a/pkg/sourcer/examples/simple_source/impl/simple_source.go +++ b/pkg/sourcer/examples/simple_source/impl/simple_source.go @@ -2,7 +2,6 @@ package impl import ( "context" - "log" "strconv" "sync" "time" @@ -30,7 +29,6 @@ func NewSimpleSource() *SimpleSource { func (s *SimpleSource) Pending(_ context.Context) int64 { s.lock.Lock() defer s.lock.Unlock() - log.Println("Number of pending records: ", len(s.toAckSet)) // The simple source always returns zero to indicate there is no pending record. return int64(len(s.toAckSet)) } @@ -46,9 +44,9 @@ func (s *SimpleSource) Read(_ context.Context, readRequest sourcesdk.ReadRequest // leaving the toAckSet not empty on the UDSource container side. // In this case, for the next batch read, we should read the data from the last acked offset instead of returning. // Our built-in Kafka source follows this logic. - //if len(s.toAckSet) > 0 { - // return - //} + if len(s.toAckSet) > 0 { + return + } // Read the data from the source and send the data to the message channel. for i := 0; uint64(i) < readRequest.Count(); i++ {