-
Notifications
You must be signed in to change notification settings - Fork 439
[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
Labels
Comments
@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. |
$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. |
my guess is that somehow related to the change in ths PR #314 Cannot say how exactly, I am not much into Kafka. |
fixed in #508 |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
reload this version consumer message will reset in already read message
The text was updated successfully, but these errors were encountered: