Matthias J. Sax created KAFKA-6686:
--------------------------------------

             Summary: Allow reading topic as KStream and GlobalKTable
                 Key: KAFKA-6686
                 URL: https://issues.apache.org/jira/browse/KAFKA-6686
             Project: Kafka
          Issue Type: Bug
          Components: streams
            Reporter: Matthias J. Sax


Users often want to read topic multiple times, eg, as a stream and a table. For 
KSteam/KTable this is possible by reading the data as a KTable, disable caching 
on the KTable, and get a stream via {{toStream()}}. This pattern does not work 
for KStream/GlobalKTable though.

However, there is no need to raise an exception
{quote}Exception in thread “main” 
org.apache.kafka.streams.errors.TopologyException: Invalid topology: Topic 
source has already been registered by another source.
{quote}
for this case, because the GlobalKTable is consumer by a different consumer (in 
contrast to KStream/KTable case for which KStream and KTable use a shared 
consumer).



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to