scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-10-07 03:17:50 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

FB-1646 : UPdated code post code review

Browse source
This commit is contained in:
HHans09 2022-09-22 11:11:46 -04:00 • committed by HHans09
parent 555c8f6532
commit 3bb825a908
1 changed files with 7 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
idk/kafka/source.go
View file

@ -233,6 +233,11 @@ func (r *Record) Commit(ctx context.Context) error {
p = x.Partition
}
_, err := r.src.CommitMessages(r.src.highmarks)
if err != nil {
return errors.Wrap(err, "failed to commit messages")
}
r.src.spool = remaining
r.src.spoolBase = idx
return nil
@ -298,7 +303,8 @@ func (s *Source) Open() error {
return err
}
s.Log.Debugf(buf.String())
stv, iv := confluent.LibraryVersion()
s.Log.Debugf("version:(%v) %v", iv, stv)
}
cl, err := confluent.NewConsumer(s.ConfigMap)
if err != nil {