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

CAMEL-10901 Implemented support for Kafka consumer to seek to either ... #1495

Closed
wants to merge 1 commit into from

Conversation

sverkera
Copy link

… beginning or end of topic on startup

@oscerd
Copy link
Contributor

oscerd commented Feb 27, 2017

Since we are changing the old behavior maybe it can be better if you add something in the .adoc file.
I mean a little section where you describe how the behavior changed.

@davsclaus
Copy link
Contributor

Yeah the seek to beginning is from CAMEL-9716. So it may be better to have seekToEnd as new option, so its backwards compatible

@sverkera
Copy link
Author

I did implement at first like Claus suggests, but as these are conflicting parameters and the usual way to implement that in Camel is to use an enum I changed to that instead.

As seekToBeginning functionality was added in 2.19.0-SNAPSHOT it has never been part of a release version and hence it is better in my opinion to keep consistent with how other parameters are handled. I have added a note in the description about it as Andrea suggests.

@sverkera
Copy link
Author

Ok, it wasn't mentioned on http://camel.apache.org/kafka.html and fix version of CAMEL-9716 said 2.19.0 so that was why I missed it.

Still in my opinion it is better to keep consistency but if you prefer I can implement it as seekToEnd and throw an exception if they are set to conflicting values.

@davsclaus
Copy link
Contributor

Yeah its better with a seekToEnd option.

@oscerd
Copy link
Contributor

oscerd commented Feb 27, 2017

We will wait for your fix, by the way add a note in the docs with an example would be nice

@sverkera
Copy link
Author

There are no backwards compatibility anyway on the kafka component between 2.19.x and 2.18.x as there are fundamental changes in how brokers and topic are specified:

2.18.x:
kafka:mybrokers?topic=mytopic

2.19.x:
kafka:mytopic?brokers=mybrokers

@davsclaus
Copy link
Contributor

You can have a point that users would need to migrate and that seek to beginning was only added in 2.18.x so its only 1 release back.

So we can likely just do the seekTo stuff. And add a note in the 2.19 release note about the option change

@sverkera
Copy link
Author

I would vote for that but it's up to you to decide.

@davsclaus
Copy link
Contributor

Thanks for the PR it has been merged. Do you mind closing this?

@oscerd
Copy link
Contributor

oscerd commented Feb 27, 2017

I was waiting for your opinion before merging @davsclaus

By the way that's fine :-)

@sverkera
Copy link
Author

Thank you

@sverkera sverkera closed this Feb 27, 2017
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
3 participants