| Package | Description |
|---|---|
| com.github.hackerwin7.jlib.utils.drivers.kafka.data |
| Modifier and Type | Method and Description |
|---|---|
static KafkaMsg.KafkaMsgBuilder |
KafkaMsg.createBuilder()
create builder
|
KafkaMsg.KafkaMsgBuilder |
KafkaMsg.KafkaMsgBuilder.key(String key) |
KafkaMsg.KafkaMsgBuilder |
KafkaMsg.KafkaMsgBuilder.nextOffset(long nextOffset) |
KafkaMsg.KafkaMsgBuilder |
KafkaMsg.KafkaMsgBuilder.offset(long offset) |
KafkaMsg.KafkaMsgBuilder |
KafkaMsg.KafkaMsgBuilder.partition(int partition) |
KafkaMsg.KafkaMsgBuilder |
KafkaMsg.KafkaMsgBuilder.topic(String topic) |
KafkaMsg.KafkaMsgBuilder |
KafkaMsg.KafkaMsgBuilder.val(byte[] val) |
Copyright © 2016. All rights reserved.