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

UPdated the code to remove declared but unused variables - committedOffsets, stv & iv

Browse source
This commit is contained in:
HHans09 2022-09-21 13:46:30 -04:00 • committed by HHans09
parent 80281edaee
commit d19b7ac841
1 changed files with 1 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
idk/kafka/source.go
View file

@ -232,11 +232,7 @@ func (r *Record) Commit(ctx context.Context) error {
s = *x.Topic
p = x.Partition
}
committedOffsets, 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
@ -302,7 +298,6 @@ func (s *Source) Open() error {
return err
}
s.Log.Debugf(buf.String())
stv, iv := confluent.LibraryVersion()
}
cl, err := confluent.NewConsumer(s.ConfigMap)