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 |
Stats
| MD5 | 1f90ce14d1c9130546290a9e69c3304b |
| Eval Count | 0 |
| Decode Time | 97 ms |