feat: Kafka Consumer Package (#342)

beatlabs · Apr 2, 2021 · 8e1f756 · 8e1f756
1 parent 9ebf247
commit 8e1f756
Show file tree

Hide file tree

Showing 471 changed files with 57,710 additions and 55,203 deletions.
diff --git a/component/async/kafka/group/group_test.go b/component/async/kafka/group/group_test.go
@@ -159,6 +159,7 @@ func (m *mockConsumerSession) MemberID() string           { return "" }
 func (m *mockConsumerSession) GenerationID() int32        { return 0 }
 func (m *mockConsumerSession) MarkOffset(string, int32, int64, string) {
 }
+func (m *mockConsumerSession) Commit() {}
 func (m *mockConsumerSession) ResetOffset(string, int32, int64, string) {
 }
 func (m *mockConsumerSession) MarkMessage(*sarama.ConsumerMessage, string) {}