API for rkafka
Using Apache 'Kafka' Messaging Queue Through 'R'

Global functions
Offset Man page
SimpleConsumer Man page
SimpleConsumerObj Man page Man page
autoCommitEnable Man page
autoCommitInterval Man page
autoOffsetReset Man page
batchNumMessages Man page
clientId Man page
compressedTopics Man page
compressionCodec Man page
connectionTimeOut Man page
consumerTimeoutMs Man page
groupId Man page
ip Man page
kafkaProducerBufferSize Man page
kafkaServerPort Man page
kafkaServerURL Man page
message Man page
metadataBrokerList Man page
msgReadSize Man page
partition Man page
partitionerClass Man page
producer Man page Man page
producerType Man page
queueBufferingMaxMessages Man page
queueBufferingMaxTime Man page
queueEnqueueTimeoutTime Man page
rkafka Man page
rkafka.closeConsumer Man page
rkafka.closeProducer Man page
rkafka.closeSimpleConsumer Man page
rkafka.createConsumer Man page
rkafka.createProducer Man page
rkafka.createSimpleConsumer Man page
rkafka.read Man page
rkafka.readFromSimpleConsumer Man page
rkafka.readPoll Man page
rkafka.receiveFromSimpleConsumer Man page
rkafka.send Man page
serializerClass Man page
topicName Man page Man page Man page
zookeeperConnect Man page
zookeeperConnectionTimeoutMs Man page
rkafka documentation built on May 1, 2019, 11:28 p.m.