Lucas Brutschy created KAFKA-18917:
--------------------------------------

             Summary: 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


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)

Reply via email to