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
How to break messages when ingesting into kafka #313
Comments
Hello.
|
|
You can implement a processor. Each S3ObjectInputStream can be read and you can read the data for example 1 Mb |
By the way, it's better to discuss this on the mailing list to avoid confusion. |
Thanks for the help. |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
I wanted to break messages before sending to kafka endpoint.
Is it possible to do with processors ?
I am trying to send S3 files data to kafka using s3 and kafka components.
How do i break messages before sending to kafka ?
The text was updated successfully, but these errors were encountered: