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

Method Commit

offset_manager.go:26–26  ·  view source on GitHub ↗

Commit commits the offsets. This method can be used if AutoCommit.Enable is set to false.

()

Source from the content-addressed store, hash-verified

24 // Commit commits the offsets. This method can be used if AutoCommit.Enable is
25 // set to false.
26 Commit()
27}
28
29type offsetManager struct {

Callers 8

TestFuncAdminListConsumerGroupOffsetsFunction · 0.65
TestFuncAdminListConsumerGroupOffsetsBatchFunction · 0.65
TestFuncAdminDeleteGroupFunction · 0.65
TestFuncOffsetManagerFunction · 0.65
TestOffsetManagerCommitSequenceFunction · 0.65
TestOffsetManagerCommitConcurrentDeadlockFunction · 0.65
TestNewOffsetManagerOffsetsManualCommitFunction · 0.65
TestFuncConsumerGroupOffsetDeletionFunction · 0.65

Implementers 1

offsetManageroffset_manager.go

Calls

no outgoing calls

Tested by 8

TestFuncAdminListConsumerGroupOffsetsFunction · 0.52
TestFuncAdminListConsumerGroupOffsetsBatchFunction · 0.52
TestFuncAdminDeleteGroupFunction · 0.52
TestFuncOffsetManagerFunction · 0.52
TestOffsetManagerCommitSequenceFunction · 0.52
TestOffsetManagerCommitConcurrentDeadlockFunction · 0.52
TestNewOffsetManagerOffsetsManualCommitFunction · 0.52
TestFuncConsumerGroupOffsetDeletionFunction · 0.52