So I have this use case I'm not too sure how to address:
```
val stateStore = "store"
val materialized = Materialized.as[String, Long,
ByteArrayKeyValueStore](stateStore)
...
table1.join(table2, materialized)((a, b) => a + b)
val testDriver = createTestDriver(builder)
...
testDriver.getKeyValueStore[String, Long](stateStore).get("1") shouldBe 2
```
To me it sounds like we should be able to get the store from/with the
`Materialized` object. It's much better typed than a `String`:
```
val materialized = Materialized.as[String, Long,
ByteArrayKeyValueStore](stateStore)
...
table1.join(table2, materialized)((a, b) => a + b)
val testDriver = createTestDriver(builder)
...
testDriver.getStore[String, Long](materialized).get("1") shouldBe 2
```
I'm not sure if that's the way to do it exactly so feel free to comment.
[ Full content available at: https://github.com/apache/kafka/pull/5550 ]
This message was relayed via gitbox.apache.org for [email protected]
