adding kafka delete functionality

This commit is contained in:
jacob 2023-03-05 23:16:59 -06:00 committed by Jacob Brinlee
parent aad32f1dbd
commit e9796e1aed

View file

@ -476,6 +476,6 @@ func (r idkRec) Data() []interface{} {
return r
}
func (r idkRec) Schema() interface{} (
func (r idkRec) Schema() interface{} {
return nil
)
}