如何在不转换 KafkaStreams 的情况下初始化 KeyValueStore？

Question

第27行代码：github

我们可以看看Kafka Streams in Action这本书的作者是如何初始化KeyValueStore的。他使用脏转换(KeyValueStore)。

public class PurchaseRewardTransformer implements ValueTransformer<Purchase, RewardAccumulator> {

    private KeyValueStore<String, Integer> stateStore;
    private final String storeName;
    private ProcessorContext context;

    public PurchaseRewardTransformer(String storeName) {
        Objects.requireNonNull(storeName,"Store Name can't be null");
        this.storeName = storeName;
    }

    @Override
    @SuppressWarnings("unchecked")
    public void init(ProcessorContext context) {
        this.context = context;
        stateStore = (KeyValueStore) this.context.getStateStore(storeName);
    }

// ...

如何更有礼貌？

Answer 1

ProcessorContext.getStateStore 不返回定义的存储类型，它返回一个接口，因此如果您需要使用该实现的特定方法，则必须对其进行强制转换