diff --git a/composer.json b/composer.json index 26c44346..04e4ab29 100644 --- a/composer.json +++ b/composer.json @@ -1,5 +1,5 @@ { - "name": "nmred/kafka-php", + "name": "superli/kafka-php", "description": "Kafka client for php", "type": "library", "keywords": [ diff --git a/src/Protocol/Produce.php b/src/Protocol/Produce.php index 23c87af7..dd7af518 100644 --- a/src/Protocol/Produce.php +++ b/src/Protocol/Produce.php @@ -293,7 +293,7 @@ protected function producePartitionPair(string $data, int $version): array 'data' => [ 'partition' => $partitionId, 'errorCode' => $errorCode, - 'offset' => $offset, + 'offset' => $partitionOffset, 'timestamp' => $timestamp, ], ];