Skip to content

This issue was moved to a discussion.

You can continue the conversation there. Go to discussion →

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 handle buffer data between processors chain #2202

Closed
licongchao opened this issue Nov 3, 2023 · 1 comment
Closed

How to handle buffer data between processors chain #2202

licongchao opened this issue Nov 3, 2023 · 1 comment
Labels

Comments

@licongchao
Copy link

Benthos is fantastic. I'm looking into it to solve some data processing requirements.
The requirements is to collect data from external service and do some data processing. i already added a customized input and working on the customized processor. The processor output should be buffered when specific logic/condition meets (Wait for other data to arrive and do periodical timer to deliver output result).
Is this logic suitable to be placed in the processor?

@Jeffail
Copy link
Collaborator

Jeffail commented Nov 3, 2023

Hey @licongchao, there are buffer plugins which sound like they suit your use case better: https://pkg.go.dev/github.com/benthosdev/benthos/v4@v4.23.0/public/service#Environment.RegisterBatchBuffer

Converting to a discussion as per #2026

@redpanda-data redpanda-data locked and limited conversation to collaborators Nov 3, 2023
@Jeffail Jeffail converted this issue into discussion #2203 Nov 3, 2023

This issue was moved to a discussion.

You can continue the conversation there. Go to discussion →

Labels
Projects
None yet
Development

No branches or pull requests

2 participants