Skip to content

Conversation

@accelerated
Copy link
Contributor

@accelerated accelerated commented Jan 27, 2020

Certain RdKafka errors such as RD_KAFKA_RESP_ERR__TIMED_OUT when brokers are down or undiscoverable will cause RdKafka to raise the message receive callback with a valid message payload (it needs to contain the error number), however the key and partitions are null. If Message::get_topic() is called on such a message, this is delegated to rd_kafka_topic_name(null) which unfortunately dereferences this pointer w/o checking and crashes.

@mfontanini would be great if you can prioritize this. Thanks!

@mfontanini mfontanini merged commit f1de729 into mfontanini:master Jan 27, 2020
@mfontanini
Copy link
Owner

Thanks!

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants