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
Could you advise if there are multiple partitions in one given topic, when we consume this kafka topic in this stream provider, how many Grains/Tasks/threads are used for this topic?
I read some source code, I'm not totally sure, but it seems like there would be only one thread that is consuming the message in public Task<IList<IBatchContainer>> GetQueueMessagesAsync(int maxCount) in KafkaAdapterReceiver
Thank you.
The text was updated successfully, but these errors were encountered:
Hi Team,
Could you advise if there are multiple partitions in one given topic, when we consume this kafka topic in this stream provider, how many Grains/Tasks/threads are used for this topic?
I read some source code, I'm not totally sure, but it seems like there would be only one thread that is consuming the message in
public Task<IList<IBatchContainer>> GetQueueMessagesAsync(int maxCount)
inKafkaAdapterReceiver
Thank you.
The text was updated successfully, but these errors were encountered: