You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/03/19 16:25:00 UTC

[jira] [Created] (KAFKA-6686) Allow reading topic as KStream and GlobalKTable

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)