[Question] How many Grains/Tasks/threads are used for each partition of the Kafka topic?

jonathansant / Orleans.Streams.Kafka

An implementation of a PersistentStreamProvider for Microsoft Orleans and Kafka using the Confluent API

GNU General Public License v3.0

79 stars 31 forks source link

[Question] How many Grains/Tasks/threads are used for each partition of the Kafka topic? #35

Open shykln opened 3 years ago

shykln commented 3 years ago

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) in KafkaAdapterReceiver

Thank you.