Skip to content

Commit 0beaa3e

Browse files
committed
wip
1 parent 816f6b6 commit 0beaa3e

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

docs/advanced-usage/4-custom-committers.md

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -70,9 +70,7 @@ class CustomCommitterFactory implements CommitterFactory
7070
public function make(KafkaConsumer $kafkaConsumer, Config $config): CommitterContract
7171
{
7272
return new RetryableCommitter(
73-
new SuccessCommitter(
74-
$kafkaConsumer
75-
),
73+
new SuccessCommitter($kafkaConsumer),
7674
new NativeSleeper(),
7775
$config->getMaxCommitRetries()
7876
);

0 commit comments

Comments
 (0)