[
https://issues.apache.org/jira/browse/KAFKA-18917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy updated KAFKA-18917:
-----------------------------------
Priority: Blocker (was: Critical)
> TransformValues with unnamed Materialized instance throws NPE
> -------------------------------------------------------------
>
> Key: KAFKA-18917
> URL: https://issues.apache.org/jira/browse/KAFKA-18917
> Project: Kafka
> Issue Type: Bug
> Affects Versions: 4.0.0
> Reporter: Lucas Brutschy
> Assignee: Lucas Brutschy
> Priority: Blocker
>
> In 4.0, when `transformValues` is used with a `Materialized` instance, but
> without a queryable name, a `NullPointerException` is thrown.
> {code:java}
> .transformValues(new StatelessTransformerSupplier(),
> Materialized.with(Serdes.String(), Serdes.Integer())
> ) {code}
> with the following stack trace:
> {code:java}
> java.lang.NullPointerException: stateStoreFactory can't be null
> at java.base/java.util.Objects.requireNonNull(Objects.java:235)
> at
> org.apache.kafka.streams.processor.internals.InternalTopologyBuilder.addStateStore(InternalTopologyBuilder.java:630)
> at
> org.apache.kafka.streams.processor.internals.InternalTopologyBuilder.addStateStore(InternalTopologyBuilder.java:619)
> at
> org.apache.kafka.streams.kstream.internals.graph.ProcessorParameters.addProcessorTo(ProcessorParameters.java:77)
> at
> org.apache.kafka.streams.kstream.internals.graph.ProcessorToStateConnectorNode.writeToTopology(ProcessorToStateConnectorNode.java:68)
> at
> org.apache.kafka.streams.kstream.internals.InternalStreamsBuilder.buildAndOptimizeTopology(InternalStreamsBuilder.java:322)
> at
> org.apache.kafka.streams.StreamsBuilder.build(StreamsBuilder.java:588) {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
