[ https://issues.apache.org/jira/browse/KAFKA-12151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jan Teichmann resolved KAFKA-12151. ----------------------------------- Resolution: Invalid caused by a version mismatch as suggested in the comments. > Closing the TopologyTestDriver from kafka-streams-test-utils raises > UnsupportedOperationException > ------------------------------------------------------------------------------------------------- > > Key: KAFKA-12151 > URL: https://issues.apache.org/jira/browse/KAFKA-12151 > Project: Kafka > Issue Type: Bug > Components: streams-test-utils > Affects Versions: 2.6.0 > Reporter: Jan Teichmann > Priority: Major > > Following the documentation for testing kafka streams: > [https://kafka.apache.org/26/documentation/streams/developer-guide/testing.html] > > When running > testDriver.close(); > throws an exception. > {code:java} > java.lang.UnsupportedOperationException: Removing from registeredStores is > not allowedjava.lang.UnsupportedOperationException: Removing from > registeredStores is not allowed at > org.apache.kafka.common.utils.FixedOrderMap.clear(FixedOrderMap.java:56) at > org.apache.kafka.streams.processor.internals.ProcessorStateManager.close(ProcessorStateManager.java:499) > at > org.apache.kafka.streams.processor.internals.StateManagerUtil.closeStateManager(StateManagerUtil.java:106) > at > org.apache.kafka.streams.processor.internals.StreamTask.lambda$close$0(StreamTask.java:574) > at > org.apache.kafka.streams.processor.internals.TaskManager.executeAndMaybeSwallow(TaskManager.java:1155) > at > org.apache.kafka.streams.processor.internals.TaskManager.executeAndMaybeSwallow(TaskManager.java:1169) > at > org.apache.kafka.streams.processor.internals.StreamTask.close(StreamTask.java:572) > at > org.apache.kafka.streams.processor.internals.StreamTask.closeClean(StreamTask.java:501) > at > org.apache.kafka.streams.TopologyTestDriver.close(TopologyTestDriver.java:1180) > {code} > The ProcessorStateManager.close is calling stores.clear(); however stores is > of type FixedOrderMap which implements > {code:java} > @Deprecated > @Override > public void clear() { throw new UnsupportedOperationException("Removing from > registeredStores is not allowed"); } > {code} > and therefore can only ever fail. This worked fine with version 2.5 > {{}} -- This message was sent by Atlassian Jira (v8.3.4#803005)