Jan Teichmann created KAFKA-12151:
-------------------------------------
Summary: 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
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)
