Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-7833

StreamsBuilder should throw an exception if addGlobalStore and addStateStore is called for the same store builder

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 2.1.0
    • 2.6.0
    • streams

    Description

      StoreBuilder<KeyValueStore<String, String>> storeBuilder =
      {{ Stores.keyValueStoreBuilder(Stores.inMemoryKeyValueStore("global-store"), null, null);}}

      {{ builder.addGlobalStore(}}
      {{ storeBuilder,}}
      {{ "global-topic",}}
      {{ Consumed.with(null, null),}}
      {{ new KTableSource(storeBuilder.name())}}
      {{ );}}

      {{builder.addStateStore(storeBuilder); }}

      builder.build();

       

       

      Does not throw an exception.

       

      cc mjsax

      Attachments

        Activity

          People

            chebbyChef Rob Meng
            slendle Sam Lendle
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: