KafkaStorage

java.lang.Object
- cz.o2.proxima.direct.io.kafka.KafkaStorage

All Implemented Interfaces:

AbstractDataAccessorFactory<DirectDataOperator,DataAccessor>, DataAccessorFactory, java.io.Serializable
```
@AutoService(DataAccessorFactory.class)
public class KafkaStorage
extends java.lang.Object
implements DataAccessorFactory
```
Storage using KafkaProducer.

See Also:

Serialized Form

Nested Class Summary
- Nested classes/interfaces inherited from interface cz.o2.proxima.core.storage.internal.AbstractDataAccessorFactory
  AbstractDataAccessorFactory.Accept

Constructor Summary

Constructors
Constructor Description

KafkaStorage()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`AbstractDataAccessorFactory.Accept`	`accepts(java.net.URI uri)`	Check if this factory can create accessors for given URI.
`DataAccessor`	`createAccessor(DirectDataOperator operator, AttributeFamilyDescriptor familyDescriptor)`	Create the accessor for give `AttributeFamilyDescriptor`.

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

Methods inherited from interface cz.o2.proxima.core.storage.internal.AbstractDataAccessorFactory
setup

- Constructor Detail
  - KafkaStorage
```
public KafkaStorage()
```
- Method Detail
  - createAccessor
```
public DataAccessor createAccessor(DirectDataOperator operator,
                                   AttributeFamilyDescriptor familyDescriptor)
```
    Description copied from interface: AbstractDataAccessorFactory
    
    Create the accessor for give AttributeFamilyDescriptor.
    
    Specified by:
    
    createAccessor in interface AbstractDataAccessorFactory<DirectDataOperator,DataAccessor>
    
    Parameters:
    
    operator - operator to create the accessor for
    
    familyDescriptor - attribute family descriptor
    
    Returns:
    
    AbstractDataAccessor for given operator and family
  - accepts
```
public AbstractDataAccessorFactory.Accept accepts(java.net.URI uri)
```
    Description copied from interface: AbstractDataAccessorFactory
    
    Check if this factory can create accessors for given URI.
    
    Specified by:
    
    accepts in interface AbstractDataAccessorFactory<DirectDataOperator,DataAccessor>
    
    Parameters:
    
    uri - the URI to create accessor for
    
    Returns:
    
    acception mark