Add return code for Kafka::produce and free message payload memory in rd_kafka_example when queue is full #12

ZhuYouzhi · 2013-06-05T02:30:06Z

Hi, Edenhill.

Many thanks for you reply.

I've made a clear patch and pull it for your review.

Changes:
(1) Add return code for Kafka::produce
(2) Free message payload memory in rd_kafka_example

edenhill · 2013-08-09T22:47:27Z

Thanks for you contribution!

Add return code for Kafka::produce and free message payload memory in rd_kafka_example when queue is full

Add return code for Kafka::produce; Free payload when rkq is full

b6fff10

edenhill added a commit that referenced this pull request Aug 9, 2013

Merge pull request #12 from ZhuYouzhi/master

bac7e27

Add return code for Kafka::produce and free message payload memory in rd_kafka_example when queue is full

edenhill merged commit bac7e27 into confluentinc:master Aug 9, 2013

xiaojun789 mentioned this pull request Nov 8, 2013

crashes on too large messages #24

Closed

winbatch mentioned this pull request Dec 27, 2013

static linking of librdkafka.a needs dynamic pthreads linking #34

Closed

winbatch mentioned this pull request Feb 11, 2014

Crash on exit #72

Closed

laxpio mentioned this pull request Aug 4, 2014

Crash on invalid partition in Metadata #132

Closed

laxpio mentioned this pull request Oct 9, 2014

Crash on rd_kafka_topic_metadata_update #155

Closed

affranchi mentioned this pull request Mar 26, 2015

Seg fault with multi brokers #224

Closed

mahb94 mentioned this pull request Apr 21, 2015

client consume from kafka crushed occasionally #254

Closed

ylgeeker mentioned this pull request Aug 28, 2015

rd_kafka_topic_destroy0 will crash ?? @ 0.8.6 #360

Closed

DEvil0000 mentioned this pull request Oct 12, 2015

rdkafka stopping connection retries on RdKafka::ERR__ALL_BROKERS_DOWN #373

Closed

ago3x mentioned this pull request Jan 6, 2016

autocommit offset does not work if i use high level api #480

Closed

coolulu mentioned this pull request Jan 7, 2016

Question of rdkafka_consumer_example_cpp #497

Closed

microwish mentioned this pull request Jan 25, 2016

Consumer segfault @ rd_kafka_broker_metadata_req_op #518

Closed

trthulhu mentioned this pull request Feb 5, 2016

rdkafka crashes when topic is too long (255 characters) sometimes #529

Closed

wucanhui mentioned this pull request Feb 22, 2016

rdkafka_partition.c:165:rd_kafka_toppar_remove: assert: rktp->rktp_removed==0 #558

Closed

trthulhu mentioned this pull request Mar 28, 2016

Assertion `!*"refcnt sub-zero"' failed. #591

Closed

vdeters mentioned this pull request Apr 12, 2016

KafkaConsumer segfault #608

Closed

hendrik-schumacher mentioned this pull request Apr 21, 2016

librdkafka hanging on rd_kafka_destroy() #624

Closed

mlala-pan mentioned this pull request Aug 5, 2016

Consuming from multiple topics partitions from a single thread causing an assert #748

Closed

trthulhu mentioned this pull request Aug 18, 2016

hang on rd_kafka_destroy() in repetitive, quick succession #747

Closed

9 tasks

trthulhu mentioned this pull request Sep 7, 2016

Core rd_kafka_buf_grow assertion failure during rapid usage of consumer #781

Closed

9 tasks

abhisharma mentioned this pull request Oct 14, 2016

librdkafka on IBM machine with native compiler #837

Closed

9 tasks

yanzhiqiang mentioned this pull request Oct 20, 2016

consumer crash #846

Closed

9 tasks

This was referenced Dec 2, 2016

Librdkafka hangs on #923

Closed

library hangs on deleting the instance #932

Closed

longtong mentioned this pull request Sep 27, 2016

legacy consumer coredump on 0.8.6 #801

Closed

9 tasks

greatt1n mentioned this pull request Jan 16, 2017

Hangs on rd_kafka_flush #999

Closed

benli123 mentioned this pull request Mar 17, 2017

librdkafka crashes due to seemingly racing condition #1125

Closed

9 tasks

DavidLiuXh mentioned this pull request Apr 26, 2017

crash when add new partition #1193

Closed

9 tasks

ameyapg mentioned this pull request May 2, 2018

Crash observed consistently while calling begin() ( seems to have an invalid/corrupted iterator) on the vector of pointers to partition metadata of one of the topics #1790

Closed

7 tasks

hulaxiaodai mentioned this pull request May 16, 2018

SIGSEGV in TopicImpl.cpp partitioner_cb_trampoline #162

Closed

vk-coder mentioned this pull request May 16, 2018

threads not getting cleaned up #1803

Closed

7 tasks

TomGitter mentioned this pull request Jun 20, 2018

program crashed for rd_kafka_tppar_t was used after destroy #1846

Closed

7 tasks

blackeyepanda mentioned this pull request Jul 2, 2018

librdkafka hang during reference count problem #1872

Closed

7 tasks

hulaxiaodai mentioned this pull request Jul 16, 2018

Crash when producer get different meta. #1884

Closed

4 tasks

hulaxiaodai mentioned this pull request Nov 7, 2018

【producer】deadlock on metadata requery #2092

Closed

4 tasks

matthrae mentioned this pull request Nov 8, 2018

Assertion `!*"refcnt sub-zero"' after reconnect #2088

Closed

pradeepp2019 mentioned this pull request Apr 23, 2019

Query on Async programming (Seastar) with librdkafka #2292

Closed

MockingJayWong mentioned this pull request Jul 9, 2019

rd_kafka_topic_new after using admin api #2399

Closed

7 tasks

MockingJayWong mentioned this pull request Aug 2, 2019

rd_kafka_toppar_enq_msg() lock when produce msg #2447

Closed

7 tasks

sarkanyi mentioned this pull request Sep 9, 2019

Recovery takes too long after stopping and restarting a broker in a cluster #2508

Closed

3 tasks

hyhtemple mentioned this pull request Oct 14, 2019

use the produce of the librdkafka c++ interface ,the program report "Program terminated with signal 6, Aborted" #2571

Closed

aelanthi mentioned this pull request Dec 16, 2019

confluent python kafka client still crashes after 1.0.1 upgrade #2658

Closed

7 tasks

hyhtemple mentioned this pull request Jun 30, 2020

It is crashed ,when use method of the producer in the thread #2947

Closed

dshivashankar1994 mentioned this pull request Jul 6, 2020

rd_refcnt_sub0: Assertion `!*"refcnt sub-zero"' failed - when the subscribed topic is deleted #2963

Closed

Furuta-Masakazu-quick mentioned this pull request Sep 29, 2020

Producer detects "All broker connections are down" when rolling restarts #3090

Closed

7 tasks

taj-uddin mentioned this pull request Apr 15, 2021

High CPU usage in librdkafka1.4.0 producer #2986

Closed

7 tasks

johncagle mentioned this pull request Sep 22, 2021

segfault in rd_kafka_msgq_set_metadata() from /lib64/librdkafka.so.1 (corrupt TAILQ) #3559

Open

7 tasks

thmic mentioned this pull request Nov 29, 2024

segmentation fault from rdkafka_topic.c #4907

Open

7 tasks

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Add return code for Kafka::produce and free message payload memory in rd_kafka_example when queue is full #12

Add return code for Kafka::produce and free message payload memory in rd_kafka_example when queue is full #12

ZhuYouzhi commented Jun 5, 2013

edenhill commented Aug 9, 2013

Add return code for Kafka::produce and free message payload memory in rd_kafka_example when queue is full #12

Add return code for Kafka::produce and free message payload memory in rd_kafka_example when queue is full #12

Conversation

ZhuYouzhi commented Jun 5, 2013

edenhill commented Aug 9, 2013