[
https://issues.apache.org/jira/browse/KAFKA-6894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16470980#comment-16470980
]
ASF GitHub Bot commented on KAFKA-6894:
---------------------------------------
rayokota opened a new pull request #5000: KAFKA-6894: Fix
InternalTopologyBuilder.connectProcessAndState for global stores
URL: https://github.com/apache/kafka/pull/5000
This is a small change to `InternalTopologyBuilder.connectProcessAndState`
to allow global stores such as from `GlobalKTable` to be accessed from
`KStream.transform()` and others.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> Cannot access GlobalKTable store from KStream.transform()
> ---------------------------------------------------------
>
> Key: KAFKA-6894
> URL: https://issues.apache.org/jira/browse/KAFKA-6894
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 1.1.0
> Reporter: Robert Yokota
> Assignee: Robert Yokota
> Priority: Minor
>
> I was trying to access a store from a {{GlobalKTable}} in
> {{KStream.transform()}}, but I got the following error:
> {code}
> org.apache.kafka.streams.errors.TopologyException: Invalid topology:
> StateStore globalStore is not added yet.
> at
> org.apache.kafka.streams.processor.internals.InternalTopologyBuilder.connectProcessorAndStateStore(InternalTopologyBuilder.java:716)
> at
> org.apache.kafka.streams.processor.internals.InternalTopologyBuilder.connectProcessorAndStateStores(InternalTopologyBuilder.java:615)
> at
> org.apache.kafka.streams.kstream.internals.KStreamImpl.transform(KStreamImpl.java:521)
> {code}
> I was able to make a change to
> {{InternalTopologyBuilder.connectProcessorAndState}} to allow me to access
> the global store from {{KStream.transform()}}. I will submit a PR for review.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
