#What nest kafka omited eachMessage and eachBatch from run options?

17 messages · Page 1 of 1 (latest)

obtuse cloak
#

is there any special reason omited eachMessage and eachBatch message?
run?: Omit<ConsumerRunConfig, "eachBatch" | "eachMessage">

twilit cedarBOT
#

Please do not tag the moderators unless someone is breaking server rules. The mods are here to help enforce the rules of the server, and while most of them are knowledgeable about Nest, they are not the only ones able to solve your question.

dry vault
#

Yes, because subscribing to messages is done through EventPattern decorators. This information is collected by the transport adapter and passed to the underlying eachMessage option. The eachBatch behavior is not supported at all (unless you write a custom transport adapter)

obtuse cloak
#

in that can I create custom partition ?

obtuse cloak
#

@dry vault in that case how can I create custom partition?

dry vault