autoCommitEnable | Creating KAFKA consumer |
autoCommitInterval | Creating KAFKA consumer |
autoOffsetReset | Creating KAFKA consumer |
batchNumMessages | Creating KAFKA producer |
clientId | Creating simple KAFKA consumer |
compressedTopics | Creating KAFKA producer |
compressionCodec | Creating KAFKA producer |
connectionTimeOut | Creating simple KAFKA consumer |
consumerTimeoutMs | Creating KAFKA consumer |
groupId | Creating KAFKA consumer |
ip | KAFKA producer sending message |
kafkaProducerBufferSize | Creating simple KAFKA consumer |
kafkaServerPort | Creating simple KAFKA consumer |
kafkaServerURL | Creating simple KAFKA consumer |
message | KAFKA producer sending message |
metadataBrokerList | Creating KAFKA producer |
msgReadSize | KAKFA Simple Consumer receiving messages |
Offset | KAKFA Simple Consumer receiving messages |
partition | KAKFA Simple Consumer receiving messages |
partitionerClass | Creating KAFKA producer |
producerType | Creating KAFKA producer |
queueBufferingMaxMessages | Creating KAFKA producer |
queueBufferingMaxTime | Creating KAFKA producer |
queueEnqueueTimeoutTime | Creating KAFKA producer |
rkafka | Using Apache 'Kafka' Messaging Queue Through 'R' |
rkafka.closeConsumer | Closing KAKFA consumer |
rkafka.closeProducer | KAFKA producer shutdown |
rkafka.closeSimpleConsumer | Closing KAKFA Simple consumer |
rkafka.createConsumer | Creating KAFKA consumer |
rkafka.createProducer | Creating KAFKA producer |
rkafka.createSimpleConsumer | Creating simple KAFKA consumer |
rkafka.read | KAFKA consumer reading messages(single) |
rkafka.readFromSimpleConsumer | KAFKA Simple Consumer Reading |
rkafka.readPoll | KAFKA consumer reading messages(batch) |
rkafka.receiveFromSimpleConsumer | KAKFA Simple Consumer receiving messages |
rkafka.send | KAFKA producer sending message |
serializerClass | Creating KAFKA producer |
SimpleConsumer | Closing KAKFA Simple consumer |
SimpleConsumerObj | KAFKA Simple Consumer Reading |
topicName | KAFKA producer sending message |
zookeeperConnect | Creating KAFKA consumer |
zookeeperConnectionTimeoutMs | Creating KAFKA consumer |