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

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

        $topic      = self::encodeString($values['topic_name'], self::PACK_INT16);
        $partitions = self::encodeArray($values['partitions'], [$this, 'encodeProducePartition'], $compression);

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

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

        $topic      = self::encodeString($values['topic_name'], self::PACK_INT16);
        $partitions = self::encodeArray($values['partitions'], [$this, 'encodeProducePartition'], $compression);

        return $topic . $partitions;
    }
protected function encodeProduceTopic ( array $ values , int $ compression ) : string { if ( ! isset ( $ values [ 'topic_name' ] ) ) { throw new ProtocolException ( 'given produce data invalid. `topic_name` is undefined.' ) ; } if ( ! isset ( $ values [ 'partitions' ] ) || empty ( $ values [ 'partitions' ] ) ) { throw new ProtocolException ( 'given produce data invalid. `partitions` is undefined.' ) ; } $ topic = self :: encodeString ( $ values [ 'topic_name' ] , self :: PACK_INT16 ) ; $ partitions = self :: encodeArray ( $ values [ 'partitions' ] , [ $ this , 'encodeProducePartition' ] , $ compression ) ; return $ topic . $ partitions ; }
encode signal topic

@param mixed[] $values

@throws NotSupported
@throws ProtocolException
encode signal topic