Find this useful? Enter your email to receive occasional updates for securing PHP code.

Signing you up...

Thank you for signing up!

PHP Decode

<?php namespace RdKafka; class KafkaConsumer { /** * @param Conf $conf */ ..

Decoded Output download

<?php

namespace RdKafka;

class KafkaConsumer
{
    /**
     * @param Conf $conf
     */
    public function __construct(Conf $conf)
    {
    }

    /**
     * @param TopicPartition[] $topic_partitions
     *
     * @throws Exception
     * @return void
     */
    public function assign($topic_partitions = null)
    {
    }

    /**
     * @param null|Message|TopicPartition[] $message_or_offsets
     *
     * @throws Exception
     * @return void
     */
    public function commit($message_or_offsets = null)
    {
    }

    /**
     * @param string $message_or_offsets
     *
     * @throws Exception
     * @return void
     */
    public function commitAsync($message_or_offsets = null)
    {
    }

    /**
     * @param int $timeout_ms
     *
     * @throws Exception
     * @throws \InvalidArgumentException
     * @return Message
     */
    public function consume($timeout_ms)
    {
    }

    /**
     * @throws Exception
     * @return TopicPartition[]
     */
    public function getAssignment()
    {
    }

    /**
     * @param bool                    $all_topics
     * @param KafkaConsumerTopic|null $only_topic
     * @param int                     $timeout_ms
     *
     * @throws Exception
     * @return Metadata
     */
    public function getMetadata($all_topics, $only_topic, $timeout_ms)
    {
    }

    /**
     * @return array
     */
    public function getSubscription()
    {
    }

    /**
     * @param string    $topic_name
     * @param TopicConf $topic_conf
     *
     * @return KafkaConsumerTopic
     */
    public function newTopic($topic_name, TopicConf $topic_conf = null)
    {
    }

    /**
     * @param array $topics
     *
     * @throws Exception
     * @return void
     */
    public function subscribe($topics)
    {
    }

    /**
     * @throws Exception
     * @return void
     */
    public function unsubscribe()
    {
    }

    /**
     * @param TopicPartition[] $topicPartitions
     * @param int              $timeout_ms Timeout in milliseconds
     *
     * @throws Exception
     * @return TopicPartition[]
     */
    public function getCommittedOffsets($topicPartitions, $timeout_ms)
    {
    }

    /**
     * @param array $topicPartitions
     * @param int   $timeout_ms
     * @return array
     */
    public function offsetsForTimes($topicPartitions, $timeout_ms)
    {
    }

    /**
     * @param string $topic
     * @param int $partition
     * @param int $low
     * @param int $high
     * @param int $timeout_ms
     */
    public function queryWatermarkOffsets($topic, $partition, &$low, &$high, $timeout_ms)
    {
    }

    /**
     * @param array $topics
     *
     * @throws Exception
     * @return array
     */
    public function getOffsetPositions($topics)
    {
    }

    /**
     * @return void
     */
    public function close()
    {
    }

    /**
     * @param TopicPartition[] $topic_partitions
     * @return TopicPartition[]
     */
    public function pausePartitions($topic_partitions)
    {
    }

    /**
     * @param TopicPartition[] $topic_partitions
     * @return TopicPartition[]
     */
    public function resumePartitions($topic_partitions)
    {
    }
}
 ?>

Did this file decode correctly?

Original Code

<?php

namespace RdKafka;

class KafkaConsumer
{
    /**
     * @param Conf $conf
     */
    public function __construct(Conf $conf)
    {
    }

    /**
     * @param TopicPartition[] $topic_partitions
     *
     * @throws Exception
     * @return void
     */
    public function assign($topic_partitions = null)
    {
    }

    /**
     * @param null|Message|TopicPartition[] $message_or_offsets
     *
     * @throws Exception
     * @return void
     */
    public function commit($message_or_offsets = null)
    {
    }

    /**
     * @param string $message_or_offsets
     *
     * @throws Exception
     * @return void
     */
    public function commitAsync($message_or_offsets = null)
    {
    }

    /**
     * @param int $timeout_ms
     *
     * @throws Exception
     * @throws \InvalidArgumentException
     * @return Message
     */
    public function consume($timeout_ms)
    {
    }

    /**
     * @throws Exception
     * @return TopicPartition[]
     */
    public function getAssignment()
    {
    }

    /**
     * @param bool                    $all_topics
     * @param KafkaConsumerTopic|null $only_topic
     * @param int                     $timeout_ms
     *
     * @throws Exception
     * @return Metadata
     */
    public function getMetadata($all_topics, $only_topic, $timeout_ms)
    {
    }

    /**
     * @return array
     */
    public function getSubscription()
    {
    }

    /**
     * @param string    $topic_name
     * @param TopicConf $topic_conf
     *
     * @return KafkaConsumerTopic
     */
    public function newTopic($topic_name, TopicConf $topic_conf = null)
    {
    }

    /**
     * @param array $topics
     *
     * @throws Exception
     * @return void
     */
    public function subscribe($topics)
    {
    }

    /**
     * @throws Exception
     * @return void
     */
    public function unsubscribe()
    {
    }

    /**
     * @param TopicPartition[] $topicPartitions
     * @param int              $timeout_ms Timeout in milliseconds
     *
     * @throws Exception
     * @return TopicPartition[]
     */
    public function getCommittedOffsets($topicPartitions, $timeout_ms)
    {
    }

    /**
     * @param array $topicPartitions
     * @param int   $timeout_ms
     * @return array
     */
    public function offsetsForTimes($topicPartitions, $timeout_ms)
    {
    }

    /**
     * @param string $topic
     * @param int $partition
     * @param int $low
     * @param int $high
     * @param int $timeout_ms
     */
    public function queryWatermarkOffsets($topic, $partition, &$low, &$high, $timeout_ms)
    {
    }

    /**
     * @param array $topics
     *
     * @throws Exception
     * @return array
     */
    public function getOffsetPositions($topics)
    {
    }

    /**
     * @return void
     */
    public function close()
    {
    }

    /**
     * @param TopicPartition[] $topic_partitions
     * @return TopicPartition[]
     */
    public function pausePartitions($topic_partitions)
    {
    }

    /**
     * @param TopicPartition[] $topic_partitions
     * @return TopicPartition[]
     */
    public function resumePartitions($topic_partitions)
    {
    }
}

Function Calls

None

Variables

None

Stats

MD5 1f90ce14d1c9130546290a9e69c3304b
Eval Count 0
Decode Time 97 ms