-
-
Notifications
You must be signed in to change notification settings - Fork 39
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
Switch #41
Conversation
CHANGELOG.md
Outdated
|
||
- #37 - ack level for producer | ||
- Gem bump | ||
- Ruby 2.4.2 support | ||
- Raw ruby-kafka driver is not replaced with delivery_boy |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
not
-> now
README.md
Outdated
|
||
- Thread safe | ||
- Supports sync producer | ||
- Supports async producer |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
We could changes this to Supports sync and async producers
README.md
Outdated
config.kafka.seed_brokers = ['localhost:9092'] | ||
config.raise_on_failure = true | ||
config.deliver = true | ||
config.kafka.seed_brokers = ['kafka://localhost:9092'] |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
%w(kafka://localhost:9092)
README.md
Outdated
|
||
Unfortunately, it does not yet support independent forks, however you should be fine by looking at what we require. | ||
|
||
Please run: | ||
|
||
```bash | ||
bundle exec rake | ||
bundle exec rspec spec |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
No need to pass spec
, bundle exec rspec
is enough
README.md
Outdated
|
||
[![coditsu](https://coditsu.io/assets/quality_bar.svg)](https://app.coditsu.io/karafka/repositories/waterdrop) | ||
|
||
Each pull request must pass our quality requirements. To check if everything is as it should be, we use [Coditsu](https://coditsu.io) that combines multiple linters and code analyzers for both code and documentation. | ||
Each pull request must pass our quality requirements. To check if everything is as it should be, we use [Coditsu](https://coditsu.io) that combinse multiple linters and code analyzers for both code and documentation. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
combinse
-> combines
lib/water_drop/sync_producer.rb
Outdated
# Sync producer for messages | ||
SyncProducer = Class.new(BaseProducer) | ||
# Sync producer for messages | ||
Producer = SyncProducer |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This is backwards compatibility?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
No. It is just an alias for convenience. 1.0 is totally not compatible with 0.4
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I would remove this, we should be strict, either SyncProducer
or AsyncProducer
imho.
Was hanging few days now. This changes the API so please go through readme as well.
@filiptepper feel free to review it as well.