Skip to content

[rdkafka]0.8.13 version offset reset of everyone #344

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
dongm2ez opened this issue Jan 23, 2018 · 4 comments
Closed

[rdkafka]0.8.13 version offset reset of everyone #344

dongm2ez opened this issue Jan 23, 2018 · 4 comments
Labels

Comments

@dongm2ez
Copy link

reload this version consumer message will reset in already read message

@makasim
Copy link
Member

makasim commented Jan 24, 2018

@dongm2ez not sure I am following you. Could you please provide more details on this, a code snippet that reproduces the issue would be great.

@dongm2ez
Copy link
Author

dongm2ez commented Jan 25, 2018

$config = [
    'global' => [
        'group.id' => 'CID-order',
        'client.id' => uniqid('', true),
        'sasl.mechanisms' => 'PLAIN',
        'sasl.username' => '', // my username
        'sasl.password' => '', // my password
        'security.protocol' => 'SASL_SSL',
        'ssl.ca.location' => __DIR__ . '/ca-cert',
        'message.send.max.retries' => 5
    ]
];
$url = "kafka://:@kafka-ons-internet.aliyun.com:8080?" . http_build_query($config);
$psrContext = \Enqueue\dsn_to_context($url);


$fooQueue = $psrContext->createQueue('evente-order-test');
$consumer = $psrContext->createConsumer($fooQueue);
while (true) {
    $message = $consumer->receive();
    // process a message
    var_dump($message);
    $consumer->acknowledge($message);
    // $consumer->reject($message);
}

this is my code , rdkafka ext is 3.0.4。

my test this issue if lib is 0.8.12 not have, but in 0.8.13 is not ok.

@makasim
Copy link
Member

makasim commented Jan 25, 2018

my guess is that somehow related to the change in ths PR #314

Cannot say how exactly, I am not much into Kafka.

@makasim
Copy link
Member

makasim commented Aug 21, 2018

fixed in #508

@makasim makasim closed this as completed Aug 21, 2018
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
Development

No branches or pull requests

2 participants