R
Описано, конечно, не человеческим языком и без картинок, но понять можно. Ищем раздел 3.6, далее по ссылкам по другим разделам. В сети полно примеров для big и low endian преобразований.
Size: a a a
R
VG
R
VG
VG
АН
W
АН
sub poll {
my ( $self, $delay ) = @_;
if ( !$self->{current_offset} ) {
$self->_init_last_offset_from_partition();
}
while (1) {
try {
my $messages = $self->{consumer}->fetch(
$self->{topic},
$self->{partition},
$self->{current_offset},
$DEFAULT_MAX_BYTES
);
if ( @{$messages} ) {
$self->{messages} = $messages;
last; #вместо ретурна
}
else {
sleep $delay;
}
}
catch {
confess $logger->error( "KAFKA", $_ );
}
} ## end while (1)
return 1;
} ## end sub poll
W
АН
W
АН
W
АН
W
W
W
W
W
SZ