public class ItemToProcess extends Object implements Serializable
Constructor and Description |
---|
ItemToProcess(String key,
long offset,
Object object) |
Modifier and Type | Method and Description |
---|---|
static ItemToProcess |
getItemToProcess(org.apache.kafka.clients.consumer.ConsumerRecord record) |
String |
getKey() |
Object |
getObject() |
long |
getOffset() |
String |
toString() |
public String getKey()
public Object getObject()
public long getOffset()
public static ItemToProcess getItemToProcess(org.apache.kafka.clients.consumer.ConsumerRecord record)
Copyright © 2001–2020 JBoss by Red Hat. All rights reserved.