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

Jump to bottom

[Streaming Movie Ratings] Added Interactive Queries demo and Kotlin version of application #66

Merged
merged 24 commits into from May 29, 2019
Merged

[Streaming Movie Ratings] Added Interactive Queries demo and Kotlin version of application #66

merged 24 commits into from May 29, 2019

Conversation

gAmUssA
Copy link
Contributor

@gAmUssA gAmUssA commented May 9, 2019 •
edited

Viktor Gamov and others added 20 commits May 6, 2019 20:58
🚀 initial Kotlin support
7bc5197
🛠 fixing correct dependencies versions
142ef93
@asm0dey
Adds kotlinx.serialization
d395483 
This may be usefule for future creation of universal (de)serializers
📖 first attempt for KStreams DSL
5785610
🐣refactoring
c35490f
@asm0dey
Cosmetic fixes to DSL methods
d67b246
@asm0dey
Upgrades gradle to 5.2.1 version
00d10f2
--wip-- [skip ci]
ef84c61
Added PAPI Kotlin DSL
03cc418
refactored fluent Kafka Streams api code
0fd08c3
Simplified config block in PAPI dsl
33b657d
Minor refactoring
2af9e51
--wip-- [skip ci]
9817651
Some refactorings
4e614ad 
- 🚧 kotlin demo refactoring
- 🍃 spring dependencies updates
- all works :)
Initial commit of java version of IQ example
313e532
Adding rest endpoint for state stores
05eff0d
@lavcraft
Fix Movie serializer. Add test
13b71d1
json parser for RatedMovie
4cdddfd
IQ demo for movies-store and rated-movies-store
e6c31a3
✨ refactoring
ec6fd1b 
Fixed tests
Code cleanup / formatting
@gAmUssA gAmUssA requested a review from tlberglund May 9, 2019 10:57
@gAmUssA gAmUssA changed the title Added demo of Interactive Queries and Kotlin version of Kafka Streams application [Streaming Movie Ratings] Added Interactive Queries demo and Kotlin version of application May 9, 2019
dsulimchuk
dsulimchuk reviewed May 9, 2019
View reviewed changes
streams-movie-demo/streams/src/main/java/io/confluent/demo/StreamsDemo.java Outdated
@@ -230,11 +242,11 @@ public static Properties getStreamsConfig(String kafkaBootStrapServer,
config.put(DEFAULT_KEY_SERDE_CLASS_CONFIG, Serdes.Long().getClass().getName());
config.put(DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.Double().getClass().getName());
// start from the beginning
Copy link

Choose a reason for hiding this comment

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

comment is misleading )

Copy link
Contributor Author

Choose a reason for hiding this comment

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

true to that!

Copy link
Contributor Author

Choose a reason for hiding this comment

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

removed

@gAmUssA gAmUssA merged commit 4f73576 into confluentinc:master May 29, 2019
@gAmUssA gAmUssA deleted the kotlin-streams-and-iq branch May 29, 2019 15:41
@snyk-bot snyk-bot mentioned this pull request Dec 15, 2021
Merged
This was referenced Jan 13, 2022
Open
Open
This was referenced Feb 10, 2022
Open
Open
@snyk-bot snyk-bot mentioned this pull request Apr 6, 2022
Open
@snyk-bot snyk-bot mentioned this pull request Jul 7, 2022
Open
@Karla-Isabel-Sandoval Karla-Isabel-Sandoval mentioned this pull request Jan 1, 2024
Open
@Karla-Isabel-Sandoval Karla-Isabel-Sandoval mentioned this pull request Mar 15, 2024
Open
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Reviewers

@dsulimchuk dsulimchuk dsulimchuk left review comments

@tlberglund tlberglund Awaiting requested review from tlberglund

Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

Successfully merging this pull request may close these issues.

None yet
4 participants
@gAmUssA @dsulimchuk @asm0dey @lavcraft