GitHub user rhauch opened a pull request:
https://github.com/apache/kafka/pull/255
KAFKA-2593 Key value stores can use specified serializers and deserializers
Add support for the key value stores to use specified serializers and
deserializers (aka, "serdes"). Prior to this change, the stores were limited to
only the default serdes specified in the topology's configuration and exposed
to the processors via the ProcessorContext.
Now, using InMemoryKeyValueStore and RocksDBKeyValueStore are similar: both
are parameterized on the key and value types, and both have similar multiple
static factory methods. The static factory methods either take explicit key and
value serdes, take key and value class types so the serdes can be inferred
(only for the built-in serdes for string, integer, long, and byte array types),
or use the default serdes on the ProcessorContext.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rhauch/kafka kafka-2593
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/255.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #255
----
commit 4e3c1a883ff7470ced79ed747a4fe4893630c220
Author: Randall Hauch <[email protected]>
Date: 2015-09-28T18:34:51Z
KAFKA-2593 Key value stores can use custom serializers and deserializers
Add support for the key value stores to use specified serializers and
deserializers (aka, "serdes"). Prior to this change, the stores were limited to
only the default serdes specified in the topology's configuration and exposed
to the processors via the ProcessorContext.
Now, using InMemoryKeyValueStore and RocksDBKeyValueStore are similar: both
are parameterized on the key and value types, and both have similar multiple
static factory methods. The static factory methods either take explicit key and
value serdes, take key and value class types so the serdes can be inferred
(only for the built-in serdes for string, integer, long, and byte array types),
or use the default serdes on the ProcessorContext.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
