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

KAFKA-5931: deprecate KTable#through and KTable#to #3903

Closed
wants to merge 2 commits into from

Conversation

dguy
Copy link
Contributor

@dguy dguy commented Sep 19, 2017

No description provided.

@dguy
Copy link
Contributor Author

dguy commented Sep 19, 2017

@guozhangwang, @bbejeck, @mjsax

@bbejeck
Copy link
Contributor

bbejeck commented Sep 19, 2017

Thanks, @dguy just one meta comment. Do want to add toStream()#through or toStream()#to in the deprecated description? Otherwise LGTM.

@dguy
Copy link
Contributor Author

dguy commented Sep 19, 2017

@bbejeck problem is the link tags don't work like that, so it would have to be {@code toStream().through()} etc

@guozhangwang
Copy link
Contributor

retest this please

@guozhangwang
Copy link
Contributor

LGTM. Feel free to merge after Jenkins passed.

Copy link
Member

@mjsax mjsax left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

For to() JavaDoc should be different to my suggestion of course.

* The store name must be a valid Kafka topic name and cannot contain characters other than ASCII alphanumerics, '.', '_' and '-'.
*
* @param topic the topic name
* @param queryableStoreName the state store name used for the result {@code KTable}; valid characters are ASCII
* alphanumerics, '.', '_' and '-'. If {@code null} this is the equivalent of {@link KTable#through(String)()}
* @return a {@code KTable} that contains the exact same (and potentially repartitioned) records as this {@code KTable}
* @deprecated use {@link #toStream()}
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

use {@link #toStream()} followed by {@link KStream#to(String)} and {@link StreamsBuilder#table(String)} to read back as a {@code KTable} ??

same below

@asfgit asfgit closed this in 37ec15e Sep 20, 2017
@dguy
Copy link
Contributor Author

dguy commented Sep 20, 2017

merged to trunk

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

Successfully merging this pull request may close these issues.

4 participants