Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-2590 KIP-28: Kafka Streams Checklist
  3. KAFKA-2593

KeyValueStores should not require use of the context's default serializers and deserializers

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 0.10.0.0
    • 0.10.0.0
    • streams
    • None

    Description

      Currently the InMemoryKeyValueStore is only able to use the key and value serializers and deserializers (aka, "serdes") from the ProcessingContext. This means that a Processor implementation that wants to use the InMemoryKeyValueStore can only do this if the key and value types match those set up as the default serdes in the topology's configuration.

      Additionally, the RocksDBKeyValueStore is only capable of byte[] keys and values.

      Both of these key-value stores should allow the component using them to specify the serdes for both the keys and values. As a convenience, the current behavior should still be supported, as should a way to infer the serdes for the "built-in" serializers and deserializers (e.g., strings, integers, longs, and byte arrays).

      Attachments

        Activity

          People

            rhauch Randall Hauch
            rhauch Randall Hauch
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: