(PECL rdkafka >= 0.9.1)
Introduction Class synopsis RdKafka\Producer extends RdKafka{
/* Methods */
public abortTransaction(
integer$timeout_ms
) :
void public beginTransaction(
void) :
void public commitTransaction(
integer$timeout_ms
) :
void public initTransactions(
integer$timeout_ms
) :
void/* Inherited methods */
public RdKafka::addBrokers(
string$broker_list
) :
integer public RdKafka\Metadata RdKafka::getMetadata(
bool$all_topics
,
RdKafka\Topic|null$only_topic
,
int$timeout_ms
)
public RdKafka::getOutQLen(
void) :
integer public RdKafka\Topic RdKafka::newTopic(
string$topic_name
[,
RdKafka\TopicConf$topic_conf = NULL
] )
public RdKafka::poll(
integer$timeout_ms
) :
void public RdKafka::flush(
integer$timeout_ms
) :
integer public RdKafka::purge(
integer$purge_flags
) :
integer public RdKafka::setLogLevel(
integer$level
) :
void public RdKafka::setLogger(
integer$logger_id
) :
void public RdKafka::queryWatermarkOffsets(
string$topic
,
integer$partition
,
integer&$low
,
integer&$high
,
integer$timeout_ms
) :
void public RdKafka::offsetsForTimes(
array$topicPartitions
,
integer$timeout_ms
) :
array}
See Also Table of ContentsRetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4