KafkaStreamElement

java.lang.Object
- cz.o2.proxima.core.storage.StreamElement
- - cz.o2.proxima.direct.io.kafka.KafkaStreamElement

All Implemented Interfaces:

java.io.Serializable
```
public class KafkaStreamElement
extends StreamElement
```
Data read from a kafka partition.

See Also:

Serialized Form

Nested Class Summary

Nested Classes
Modifier and Type Class Description

static class KafkaStreamElement.KafkaStreamElementSerializer

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`long`	`getOffset()`	Offset in the partition.
`int`	`getPartition()`	Partition in Kafka this element comes from.
`java.lang.String`	`toString()`

Methods inherited from class cz.o2.proxima.core.storage.StreamElement
delete, delete, deleteWildcard, deleteWildcard, deleteWildcard, deleteWildcard, dump, equals, getAttribute, getAttributeDescriptor, getEntityDescriptor, getKey, getParsed, getSequentialId, getStamp, getUuid, getValue, hashCode, hasSequentialId, isDelete, isDeleteWildcard, setParsed, upsert, upsert

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

- Method Detail
  - toString
```
public java.lang.String toString()
```
    Overrides:
    
    toString in class StreamElement
  - getPartition
```
public int getPartition()
```
    Partition in Kafka this element comes from.
  - getOffset
```
public long getOffset()
```
    Offset in the partition.