Skip to content

Commit 54e5502

Browse files
committed
Removed useless $brokerId
1 parent 7e0bed0 commit 54e5502

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/Producer/Producer.php

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -44,17 +44,17 @@ public function __construct(ProducerConfig $config)
4444
$this->partitioner = new $class();
4545
}
4646

47-
public function send(string $topic, ?string $value, ?string $key = null, array $headers = [], ?int $partitionIndex = null, ?int $brokerId = null): void
47+
public function send(string $topic, ?string $value, ?string $key = null, array $headers = [], ?int $partitionIndex = null): void
4848
{
4949
$message = new ProduceMessage($topic, $value, $key, $headers, $partitionIndex);
5050
$messages = [$message];
51-
$this->sendBatch($messages, $brokerId);
51+
$this->sendBatch($messages);
5252
}
5353

5454
/**
5555
* @param ProduceMessage[] $messages
5656
*/
57-
public function sendBatch(array $messages, ?int $brokerId = null): void
57+
public function sendBatch(array $messages): void
5858
{
5959
$config = $this->config;
6060
$broker = $this->broker;

0 commit comments

Comments
 (0)