crash when add new partition

[DavidLiuXh]

Description

This consumer producer crash when add new partition:
call stack:
(gdb) bt
#0 strlen () at ../sysdeps/x86_64/strlen.S:106
#1 0x00007ffff7b658d6 in rd_kafkap_str_cmp_str2 (b=, b=,
str=) at rdkafka_proto.h:281
#2 rd_kafka_assignor_cmp_str (_a=0x0, _b=) at rdkafka_assignor.c:389
#3 0x00007ffff7b685f1 in rd_list_find (rl=0x612248, match=0x0,
cmp=0x7ffff7b658c0 <rd_kafka_assignor_cmp_str>) at rdlist.c:222
#4 0x00007ffff7b66166 in rd_kafka_assignor_run (rkcg=0x612710, protocol_name=0x6113e0 "",
metadata=0x7ffff7b658c0 <rd_kafka_assignor_cmp_str>, members=0x0, member_cnt=0,
errstr=0x22ec4202 <error: Cannot access memory at address 0x22ec4202>, errstr_size=512)
at rdkafka_assignor.c:288
#5 0x00007ffff7b4bf46 in rd_kafka_cgrp_assignor_run (rkcg=0x612710, protocol_name=0x0, err=-139044672,
metadata=0x0, members=0x0, member_cnt=0) at rdkafka_cgrp.c:659
#6 0x00007ffff7b3a697 in rd_kafka_op_call (rk=, rko=0x7fffd400d370) at rdkafka_op.c:486
#7 0x00007ffff7b3b2e0 in rd_kafka_op_handle_std (rk=, rko=,
cb_type=) at rdkafka_op.c:527
#8 0x00007ffff7b3b31c in rd_kafka_op_handle (rk=0x612010, rko=0x7fffd400d370, cb_type=1, opaque=0x0,
callback=0x0) at rdkafka_op.c:552
#9 0x00007ffff7b35280 in rd_kafka_q_serve (rkq=0x611de0, timeout_ms=,
max_cnt=max_cnt@entry=0, cb_type=cb_type@entry=1, callback=callback@entry=0x0,
opaque=opaque@entry=0x0) at rdkafka_queue.c:428
#10 0x00007ffff7b0baa6 in rd_kafka_thread_main (arg=arg@entry=0x612010) at rdkafka.c:1159
#11 0x00007ffff7b68807 in _thrd_wrapper_function (aArg=) at tinycthread.c:624
#12 0x00007ffff65c36aa in start_thread (arg=0x7fffeffff700) at pthread_create.c:333
#13 0x00007ffff71dceed in clone () at ../sysdeps/unix/sysv/linux/x86_64/clone.S:109
(gdb)

How to reproduce

Checklist

Please provide the following information:

• librdkafka version (release number or git tag):
• Apache Kafka version:
• librdkafka client configuration:
• Operating system:
• Using the legacy Consumer
• Using the high-level KafkaConsumer
• Provide logs (with debug=.. as necessary) from librdkafka
• Provide broker log excerpts
• Critical issue

[edenhill]

Do you mean that this crash happens when you add partitions to an existing topic using kafka-topics.sh ?

How many partitions were there prior to adding?
How many topics is the consumer subscribing to?

[DavidLiuXh]

@edenhill Sorry, can't reproduce it now, But I think it's always good to check protocol_name is null for strlen.

[edenhill]

Fixed.

Thanks

[agis]

@edenhill I guess this should probably be re-opened given confluentinc/confluent-kafka-go#71 (comment).

[agis]

Fixed by af3ceb3?

[edenhill]

@agis yep, thanks, I was trying to find this issue :)