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

New api #23

Merged
merged 13 commits into from
Jul 23, 2015
Merged

New api #23

merged 13 commits into from
Jul 23, 2015

Conversation

kciesielski
Copy link
Contributor

This introduces new API for creating producers / consumers.

  • It allows defining custom RequestStrategy
  • It allows passing additional kafka-specific settings

- Kafka-related properties are now grouped under ProducerProps
- The API allows defining custom RequestStrategy in order to fine tune the performance
- Old API becomes deprecated and will removed in future versions
- Kafka-related properties are now grouped under ConsumerProps
- Old API becomes deprecated and will removed in future versions
- This allows spawning the actor as own child for supervision
@@ -25,7 +25,6 @@ scalacOptions ++= Seq(
"-encoding", "UTF-8", // yes, this is 2 args
"-feature",
"-unchecked",
"-Xfatal-warnings",

Choose a reason for hiding this comment

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

just curious, what's the reason for this change?

Copy link
Contributor Author

Choose a reason for hiding this comment

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

Original intent is to guard certain level of quality. This comes from a commercial project I've been working on where such set of flags does a good job. Do you see any concerns regarding this flag?

Choose a reason for hiding this comment

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

Indeed that's a good intent. It's just that you are deleting the flag here.

Copy link
Contributor Author

Choose a reason for hiding this comment

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

Right. I wanted to keep @deprecated method calls in tests which wouldn't compile with this flag. Ultimately I resigned from this idea so I can bring it back, thanks for pointing this out.

@rintcius
Copy link

Some nice additions @kciesielski - looking forward to see them in the next version!

@markglh
Copy link
Contributor

markglh commented Jul 23, 2015

Nothing more to add from me, the changes look good!!

@jamesmorgan
Copy link
Contributor

👍 looking good

- We don't want this to get confused with Akka's Props
- We no longer call deprecated methods in tests
- Update to refactored properties class names
- Provide new, clear examples of creating consumers / producers
- Show the new way of reading from the end of the stream
- Describe how to use custom dispatcher name
@rintcius
Copy link

👍

kciesielski added a commit that referenced this pull request Jul 23, 2015

This introduces new API for creating producers / consumers.

- allows defining custom RequestStrategy
- allows passing additional kafka-specific settings
- allows setting custom dispatchers
- allows custom error handling
@kciesielski kciesielski merged commit 6065b65 into master Jul 23, 2015
@kciesielski kciesielski deleted the new-api branch July 23, 2015 19:18
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.

5 participants