Sorry, after re-reading the docs,
https://samza.apache.org/learn/documentation/0.8/jobs/configuration-table.html#stores-key-serde
I have changed it to
# Define serde
stores.store.factory=org.apache.samza.storage.kv.RocksDbKeyValueStorageEngineFactory
stores.store.key.serde=byte
stores.store.msg.serde=string
stores.store.changelog=kafka.argos-parser
Is this correct? I am still getting the same exception.
- Shekar
On Wed, Jul 1, 2015 at 5:37 PM, Shekar Tippur <ctip...@gmail.com> wrote:
> I do have this in init as well...
>
> public void init(Config config, TaskContext context) {
>
> store = (KeyValueStore<String, Integer>) context.getStore("store");
>
> }
> You are right. These are primitive types but I was trying to address this
> exception:
>
> Exception in thread "main" org.apache.samza.SamzaException: Must define a
> key serde when using key value storage.
>
> I have changed it to
>
> stores.store.key.serde=org.apache.samza.serializers.ByteSerdeFactory
>
> Regardless, exception is persisting.
>
> - Shekar
>
