Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Creating stream and associated stream with new topic, appears to be attempting to associate with another topic #285

Closed
andrew-sledge opened this issue Sep 6, 2017 · 5 comments
Assignees

Comments

@andrew-sledge
Copy link

andrew-sledge commented Sep 6, 2017

Existing topic, with data is mysite. All data if flowing through with two associated streams:

ksql> SHOW STREAMS;

 Stream Name        | Kafka Topic  | Format 
--------------------------------------------
 BIRF_BROWSER_SESSID | mysite | JSON   
 RUM_TTL_SESSID      | mysite | JSON 
ksql> CREATE STREAM ttl_browser_request WITH (kafka_topic='browser_requests', value_format='JSON') AS SELECT r.rum_ttl AS ttl, b.brand_name AS browser, r.sessid AS sessid, b.camg_reqid AS requestid FROM rum_ttl_sessid r LEFT JOIN birf_browser_sessid b ON r.requestid=b.camg_reqid;
Invalid topology building: Topic mysite has already been registered by another source.
ksql> LIST TOPICS;

 Kafka Topic        | Registered | Partitions | Partition Replicas 
-------------------------------------------------------------------
 _confluent-metrics | false      | 12         | 1                  
 _schemas           | false      | 1          | 1                  
 browser_requests   | true       | 2          | 1                  
 mysite             | true       | 1          | 1                  
 ksql__commands     | true       | 1          | 1                  
 pageviews          | false      | 1          | 1                  
 users              | false      | 1          | 1                  
ksql> 

Am I reading this correctly? How can I associate ttl_browser_request with browser_requests.

EDIT: Formatting

@hjafarpour hjafarpour self-assigned this Sep 6, 2017
@hjafarpour
Copy link
Contributor

@andrew-sledge currently we only have Stream/Table join support in KSQL. You are joining twi streams and it also seems that you are doing self join! Stream-Stream join will come soon.

@andrew-sledge
Copy link
Author

Thanks Hojjat! Looking forward to it.

@miguno
Copy link
Contributor

miguno commented Feb 21, 2018

See #731 for adding stream-stream joins.

@hinguabhishek
Copy link

can i do table-table join?

@apurvam
Copy link
Contributor

apurvam commented Jun 6, 2018

See #760 .

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

5 participants