[
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)
