API for rkafka
Using Apache 'Kafka' Messaging Queue Through 'R'
| Global functions | |
|---|---|
| .onLoad | Source code |
| 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 Source code |
| rkafka.closeProducer | Man page Source code |
| rkafka.closeSimpleConsumer | Man page Source code |
| rkafka.createConsumer | Man page Source code |
| rkafka.createProducer | Man page Source code |
| rkafka.createSimpleConsumer | Man page Source code |
| rkafka.read | Man page Source code |
| rkafka.readFromSimpleConsumer | Man page Source code |
| rkafka.readPoll | Man page Source code |
| rkafka.receiveFromSimpleConsumer | Man page Source code |
| rkafka.send | Man page Source code |
| serializerClass | Man page |
| topicName | Man page Man page Man page |
| zookeeperConnect | Man page |
| zookeeperConnectionTimeoutMs | Man page |
