public abstract static class Stores.StoreFactory
extends java.lang.Object
Constructor and Description |
---|
Stores.StoreFactory() |
Modifier and Type | Method and Description |
---|---|
Stores.ValueFactory<byte[]> |
withByteArrayKeys()
Begin to create a
KeyValueStore by specifying the keys will be byte arrays. |
Stores.ValueFactory<java.lang.Integer> |
withIntegerKeys()
Begin to create a
KeyValueStore by specifying the keys will be Integer s. |
<K> Stores.ValueFactory<K> |
withKeys(java.lang.Class<K> keyClass)
Begin to create a
KeyValueStore by specifying the keys will be either String , Integer ,
Long , or byte[] . |
abstract <K> Stores.ValueFactory<K> |
withKeys(org.apache.kafka.common.serialization.Serializer<K> keySerializer,
org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer)
Begin to create a
KeyValueStore by specifying the serializer and deserializer for the keys. |
Stores.ValueFactory<java.lang.Long> |
withLongKeys()
Begin to create a
KeyValueStore by specifying the keys will be Long s. |
Stores.ValueFactory<java.lang.String> |
withStringKeys()
Begin to create a
KeyValueStore by specifying the keys will be String s. |
public Stores.ValueFactory<java.lang.String> withStringKeys()
KeyValueStore
by specifying the keys will be String
s.public Stores.ValueFactory<java.lang.Integer> withIntegerKeys()
KeyValueStore
by specifying the keys will be Integer
s.public Stores.ValueFactory<java.lang.Long> withLongKeys()
KeyValueStore
by specifying the keys will be Long
s.public Stores.ValueFactory<byte[]> withByteArrayKeys()
KeyValueStore
by specifying the keys will be byte arrays.public <K> Stores.ValueFactory<K> withKeys(java.lang.Class<K> keyClass)
KeyValueStore
by specifying the keys will be either String
, Integer
,
Long
, or byte[]
.keyClass
- the class for the keys, which must be one of the types for which Kafka has built-in serializers and
deserializers (e.g., String.class
, Integer.class
, Long.class
, or
byte[].class
)public abstract <K> Stores.ValueFactory<K> withKeys(org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer)
KeyValueStore
by specifying the serializer and deserializer for the keys.keySerializer
- the serializer for keys; may not be nullkeyDeserializer
- the deserializer for keys; may not be null