The TMQ (TDengine Message Queue) consumer silently ignores several documented configuration parameters when…
The TMQ (TDengine Message Queue) consumer silently ignores several documented configuration parameters when…: a task in LegoFlow-SWE (Harbor dataset). For example, setting min.poll.rows to a small number still results in poll returning the default large batch size, and fetch.max.wait.ms appears to…
The task
For example, setting `min.poll.rows` to a small number still results in poll returning the default large batch size, and `fetch.max.wait.ms` appears to be disregarded entirely. The snapshot setting also has no effect when enabled.
Part of Lego-X/LegoFlow-SWE.