D
В доке написано вроде )
Из Perl не юзал, но скоро планирую )
Что значит "симулировать", сделать send() ? 😁
Size: a a a
2021 March 27
АН
Не, в том модуле который я скинул не реализованный коммит. нашел другой, Net::Kafka, там вроде все хорошо
АН
Не, в том модуле который я скинул не реализованный коммит. нашел другой, Net::Kafka, там вроде все хорошо
Об этом написано в самой доке, если что
D
Не, в том модуле который я скинул не реализованный коммит. нашел другой, Net::Kafka, там вроде все хорошо
Может туплю, но что за другой модуль ? )
D
Kafka-1.08
D
А другой какой ?
D
Не, в том модуле который я скинул не реализованный коммит. нашел другой, Net::Kafka, там вроде все хорошо
А, все ) Net-Kafka-1.06
D
Понял ) Туплю )
D
Только не понял, где не реализован коммит )))
D
И в том и в другом есть примеры. Все реализованно вроде
D
$producer->produce
$consumer->subscribe
$consumer->subscribe
VT
А почему не consume?
VT
Нужно больше тавтологии
2021 March 28
АН
$producer->produce
$consumer->subscribe
$consumer->subscribe
В случае того модуля что я кидал, когда читаешь из партиции, то передвигаемый офсет без комита не запоминается. Комит нужно делать когда хочешь чтоб кафка в следующий раз те же самые данные из очереди не давала
D
В случае того модуля что я кидал, когда читаешь из партиции, то передвигаемый офсет без комита не запоминается. Комит нужно делать когда хочешь чтоб кафка в следующий раз те же самые данные из очереди не давала
Первый?
D
А почему не consume?
Хз, надо спросить у аффтора )
D
В случае того модуля что я кидал, когда читаешь из партиции, то передвигаемый офсет без комита не запоминается. Комит нужно делать когда хочешь чтоб кафка в следующий раз те же самые данные из очереди не давала
D
commit
$err = $kafka->commit(\@tplist, $async)
$err = $kafka->commit(\@tplist, $async)
D
commit offsets to the broker. @tplist is an array of hashes with the
following keys: "topic", "partition", "offset", "metadata". If
@topic_partition_list is missing or undef, then current partition
assignment is used instead. If $async is 1, then method returns
immediately, if it is 0 or missing then method blocks until offsets are
committed.
following keys: "topic", "partition", "offset", "metadata". If
@topic_partition_list is missing or undef, then current partition
assignment is used instead. If $async is 1, then method returns
immediately, if it is 0 or missing then method blocks until offsets are
committed.