You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Dapr bulk messaging requires producer of the message to bulk it and send to side car in the application as of now. I could not find parameter setting such as linger.ms/batch.size/compression in yaml configuration.
The pure java SDK based kafka client has a way to set the following properties
linger.ms
batch.size
compression
We are requesting to add support for above parameters so that the application code does not have to bother about bulking within a given time limit and create bulk messages in a for loop. Compression will further help in improving the performance. This needs to be taken care by underlying SDK as is the case with java SDK for apache kafka.
The text was updated successfully, but these errors were encountered:
This issue has been automatically marked as stale because it has not had activity in the last 30 days. It will be closed in the next 7 days unless it is tagged (pinned, good first issue, help wanted or triaged/resolved) or other activity occurs. Thank you for your contributions.
This issue has been automatically closed because it has not had activity in the last 37 days. If this issue is still valid, please ping a maintainer and ask them to label it as pinned, good first issue, help wanted or triaged/resolved. Thank you for your contributions.
Dapr bulk messaging requires producer of the message to bulk it and send to side car in the application as of now. I could not find parameter setting such as linger.ms/batch.size/compression in yaml configuration.
The pure java SDK based kafka client has a way to set the following properties
We are requesting to add support for above parameters so that the application code does not have to bother about bulking within a given time limit and create bulk messages in a for loop. Compression will further help in improving the performance. This needs to be taken care by underlying SDK as is the case with java SDK for apache kafka.
The text was updated successfully, but these errors were encountered: