protected function encodeProducePartition(array $values, int $compression): string
    {
        if (! isset($values['partition_id'])) {
            throw new ProtocolException('given produce data invalid. `partition_id` is undefined.');
        }

        if (! isset($values['messages']) || empty($values['messages'])) {
            throw new ProtocolException('given produce data invalid. `messages` is undefined.');
        }

        $data  = self::pack(self::BIT_B32, (string) $values['partition_id']);
        $data .= self::encodeString(
            $this->encodeMessageSet((array) $values['messages'], $compression),
            self::PACK_INT32
        );

        return $data;
    }
protected function encodeProducePartition(array $values, int $compression): string
    {
        if (! isset($values['partition_id'])) {
            throw new ProtocolException('given produce data invalid. `partition_id` is undefined.');
        }

        if (! isset($values['messages']) || empty($values['messages'])) {
            throw new ProtocolException('given produce data invalid. `messages` is undefined.');
        }

        $data  = self::pack(self::BIT_B32, (string) $values['partition_id']);
        $data .= self::encodeString(
            $this->encodeMessageSet((array) $values['messages'], $compression),
            self::PACK_INT32
        );

        return $data;
    }
protected function encodeProducePartition ( array $ values , int $ compression ) : string { if ( ! isset ( $ values [ 'partition_id' ] ) ) { throw new ProtocolException ( 'given produce data invalid. `partition_id` is undefined.' ) ; } if ( ! isset ( $ values [ 'messages' ] ) || empty ( $ values [ 'messages' ] ) ) { throw new ProtocolException ( 'given produce data invalid. `messages` is undefined.' ) ; } $ data = self :: pack ( self :: BIT_B32 , ( string ) $ values [ 'partition_id' ] ) ; $ data .= self :: encodeString ( $ this -> encodeMessageSet ( ( array ) $ values [ 'messages' ] , $ compression ) , self :: PACK_INT32 ) ; return $ data ; }
encode signal part

@param mixed[] $values

@throws NotSupported
@throws ProtocolException
encode signal part