tasks.max - The maximum number of tasks that should be created for this connector. The connector may create fewer tasks if it cannot handle the specified level of parallelism.
IMPORTANT
Messages May Be Processed Out of Order For Values Greater Than 1
If you specify a value greater than 1, the connector enables parallel processing of the tasks. If your topic has multiple partition logs (allows consumers to read from the topic in parallel), messages may be processed out of order.

перепутал немного, это к sink относится а не к source

исходники почитать)

всем привет. А кто то делал стриминг данных из кафки в кликхаус средствами самого кликхауса ? Есть ли какие проблемы ?

https://clickhouse.tech/docs/en/engines/table-engines/integrations/kafka/

я делал, работает в лоб, с буферной таблицей работает на приличной скорости

но мне даже и без буфера хватило скорости

спасибо, а не помните ли приблизительные цифры сколько событий в единицу времени было ?

да там столько же сколько обычный c консьюмер может

+ есть настройки консьюмера в кх

ссылка есть?

Всем привет.
Коллеги подскажите с помощью какого SMT в кафке я могу изменить значение поля например просто выполнив над текущим значением арифметическое действие и сохранить результат в то же поле, заменив предыдущее?

А какая часть фразы "недокументированные" возможности говорит что есть ссылка?

я про видео

Те которые про ksqlDB и реактивщину

спасибо

Вот тут ещё немного про http/2 https://docs.ksqldb.io/en/latest/developer-guide/ksqldb-clients/java-client/

а про kafka и r2dbc есть  что-нибудь?

Не слышал

я