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)