MCPcopy
hub / github.com/IBM/sarama / DeleteConsumerGroupOffset

Method DeleteConsumerGroupOffset

admin.go:159–159  ·  view source on GitHub ↗

Deletes a consumer group offset

(group string, topic string, partition int32)

Source from the content-addressed store, hash-verified

157
158 // Deletes a consumer group offset
159 DeleteConsumerGroupOffset(group string, topic string, partition int32) error
160
161 // Delete a consumer group.
162 DeleteConsumerGroup(group string) error

Callers 2

TestDeleteOffsetFunction · 0.95
TestFuncConsumerGroupOffsetDeletionFunction · 0.65

Implementers 1

clusterAdminadmin.go

Calls

no outgoing calls

Tested by 2

TestDeleteOffsetFunction · 0.76
TestFuncConsumerGroupOffsetDeletionFunction · 0.52