D
Оно ?
Size: a a a
2021 March 28
D
commit()
$consumer->commit(); # commit current partition assignment (blocking call)
$consumer->commit(1); # commit current partition assignment (non-blocking call)
my $tp_list = Net::Kafka::TopicPartitionList->new();
$tp_list->add("my_topic", 0);
$tp_list->set_offset("my_topic", 0, 12345);
$consumer->commit(0, $tp_list); # commit $tp_list assignment (blocking call);
Commit offsets on broker for the provided list of partitions. If no partitions provided current assignment is committed instead.
commit_message();
my $message = $consumer->poll(1000);
$consumer->commit_message(0, $message); # commit message (blocking call);
$consumer->commit_message(1, $message); # commit message (non-blocking call);
Commit message's offset on broker for the message's partition.
$consumer->commit(); # commit current partition assignment (blocking call)
$consumer->commit(1); # commit current partition assignment (non-blocking call)
my $tp_list = Net::Kafka::TopicPartitionList->new();
$tp_list->add("my_topic", 0);
$tp_list->set_offset("my_topic", 0, 12345);
$consumer->commit(0, $tp_list); # commit $tp_list assignment (blocking call);
Commit offsets on broker for the provided list of partitions. If no partitions provided current assignment is committed instead.
commit_message();
my $message = $consumer->poll(1000);
$consumer->commit_message(0, $message); # commit message (blocking call);
$consumer->commit_message(1, $message); # commit message (non-blocking call);
Commit message's offset on broker for the message's partition.
D
Это commit для Net::Kafka либы
D
В случае того модуля что я кидал, когда читаешь из партиции, то передвигаемый офсет без комита не запоминается. Комит нужно делать когда хочешь чтоб кафка в следующий раз те же самые данные из очереди не давала
D
Во всех 3 либах вроде все есть
D
Вы это искали ?
АН
Вы это искали ?
Я нашел либу для решение своей задачи, спасибо :)
D
Я нашел либу для решение своей задачи, спасибо :)
Здорово ) 😊👍
VK
А подскажите какие модули смотреть, нужен пул воркеров для асинхронки, с ограничением кол-ва одновременно работающих.
IB
А подскажите какие модули смотреть, нужен пул воркеров для асинхронки, с ограничением кол-ва одновременно работающих.
VK
Спасибо, я думал правда найти что то ближе к AnyEvent.
Кажется к нему чуть ли не традиция - каждый перловик свой пул пишет.
Наверное и я так сделаю - мне довольно простую логику нужно добавить.
Кажется к нему чуть ли не традиция - каждый перловик свой пул пишет.
Наверное и я так сделаю - мне довольно простую логику нужно добавить.
VK
А подскажите по чату use Perl or die
недавно узнал о нем, зашел, а на следущий день смотрю забанили, может меня кто-то туда вернуть?
недавно узнал о нем, зашел, а на следущий день смотрю забанили, может меня кто-то туда вернуть?
IB
А подскажите по чату use Perl or die
недавно узнал о нем, зашел, а на следущий день смотрю забанили, может меня кто-то туда вернуть?
недавно узнал о нем, зашел, а на следущий день смотрю забанили, может меня кто-то туда вернуть?
Попробуй еще раз, админ говорит что разбанил тебя
VK
Попробуй еще раз, админ говорит что разбанил тебя
спасибо
2021 March 29
ВР
Зачем тебе эта уродская клавиатура? Gboard, как по мне, удобнее. Как минимум, на си и перле писать, ну и по-русски
В Гбоард даже в горизонтальном виде нет клавиш ctrl, alt и клавиш перемещения курсора.
SZ
Василий Степанович Родин
В Гбоард даже в горизонтальном виде нет клавиш ctrl, alt и клавиш перемещения курсора.
А нафига они нужны? (за исключением редких пассов вокруг ssh)
DF
А нафига они нужны? (за исключением редких пассов вокруг ssh)
в консоли что-то делать