Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  • Users can provide 0, 1 or 2 StoreSupplier instances.
    • The provided StoreSupplier instances must implement WindowBytesStoreSupplier.
    • In the case of providing zero StoreSupplier(s), KafkaStreams will create two persistent state stores as it does now.  The names for the stores will be auto-generated unless the user gives a name with the StreamJoined#withName method. 
    • In the case of providing one StoreSuppliers, KafkaStreams will create one persistent state store, and the StoreSupplier will create one state store. The name for the default store will be auto-generated unless the user gives a name with the StreamJoined#withName method. 
    • When providing two StoreSuppliers, the state stores for the join will come from the suppliers, and the names will come from the name given to the supplier.
  • There will be a runtime check to ensure that the values of JoinWindows match those of the provided StoreSuppliers.
  • The name of the StoreSupplier will take priority over the name given via StreamJoined#withStoreName.
  • When using any store configuration methods (disabling logging, caching, topic configurations), KafkaStreams will apply these changes to both stores. While this may seem strict, since both stores are participating in the join, it would seem prudent to have both stores configured the same way.

...