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
Use .consume(callback) from typescript. Type of "messages" in the callback is Message[] while the lib returns a single message. I have to force cast it to use it:
consumer.consume((err, msg) => {
const message = msg as unknown as RDKafka.Message;
The .consume variant with two parameters is alright
The text was updated successfully, but these errors were encountered:
Environment Information
Steps to Reproduce
Use
.consume(callback)
from typescript. Type of "messages" in the callback isMessage[]
while the lib returns a single message. I have to force cast it to use it:The .consume variant with two parameters is alright
The text was updated successfully, but these errors were encountered: