-
Notifications
You must be signed in to change notification settings - Fork 2.5k
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 reference guide #18085
Kafka reference guide #18085
Conversation
In the absence of acknowledgment, the processing is considered on error. | ||
If the consumer method receives a `Record` or a payload, the message will be acked on method return, also known as `Strategy.POST_PROCESSING`. | ||
If the consumer method returns another reactive stream or `CompletableStage`, the message will be acked when the downstream message is acked. | ||
// No, it will be ack then the produced message get acked -> Needs confirmation |
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.
To be removed.
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.
👍
docs/src/main/asciidoc/kafka.adoc
Outdated
You can also remove the limit of in-flight messages by setting `max-inflight-messages` to `0`. | ||
However, note that the Kafka Producer may block if the number of requests reaches `max.in.flight.requests.per.connection`. | ||
|
||
=== Retries |
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.
Should it be under the producing message section?
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 think we can rename this section to "Retrying message dispatch" and keep it here. I was thinking of adding the "Retrying processing" section near receiving messages/error handling. What do you think ?
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.
Almost there! Two remaining comments.
|
||
For example, if you need to send a message to a stream, from inside a REST endpoint, when receiving a POST request. | ||
In this case, you cannot use `@Outgoing` because your method has parameters. | ||
== Accessing Kafka clients directly |
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.
Add an anchor as this should be referenced from the getting started guide.
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.
Added the reference to the getting started guide
e257c88
to
263d788
Compare
@ozangunalp can you squash your commits? |
263d788
to
0e6149d
Compare
@cescoffier done |
Transform Getting started to Reference Guide
Links to other guides : Avro Serialization & Schema Registry, Kafka Streams, Dev Services