Skip to content
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.

Sign up for GitHub

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

Jump to bottom

rd_kafka_topic_new after using admin api #2399

Closed
5 of 7 tasks
MockingJayWong opened this issue Jul 9, 2019 · 3 comments
Closed
5 of 7 tasks

rd_kafka_topic_new after using admin api #2399

MockingJayWong opened this issue Jul 9, 2019 · 3 comments

Comments

@MockingJayWong
Copy link

MockingJayWong commented Jul 9, 2019 •
edited
Loading

Read the FAQ first: https://github.com/edenhill/librdkafka/wiki/FAQ

Description

environment

librdkafka version

  • librdkafka-1.0.1

Apache Kafka version

  • kafka_2.12-2.2.0

librdkafka client configuration

"queue.buffering.max.messages"="10000000"
"linger.ms"= "0"
"compression.codec"="none"
"socket.keepalive.enable"= "true"
"enable.idempotence"="true"
"message.timeout.ms"="1000"

client system version

  • Ubuntu 18.04.1 LTS

step in follow

  • after using topic admin api to make a manual topic with custom replicas and topic leader,
  • use rd_kafka_topic_new to get rd_kafka_topic_t* type object

and then segmentfault in rd_kafka_MetadataRequest somehow.

  • I find it uncomment rd_kafka_event_destroy(rkev) this line will not reproduce the problem, but i dont know why？ appreciated if help me.
  • secondly, sometimes using topic created by admin api, i cant send msg until putting a poll with timeout_ms.

How to reproduce

        rd_kafka_NewTopic_t *new_topics[3];
        new_topics[0] = rd_kafka_NewTopic_new("test_timeout36_1",1,-1,NULL, 0);
        new_topics[1] = rd_kafka_NewTopic_new("test_timeout36_2",1,-1,NULL, 0);
        new_topics[2] = rd_kafka_NewTopic_new("test_timeout36_3",1,-1,NULL, 0);

        // broker_list get
        const struct rd_kafka_metadata *metadata;
        rd_kafka_resp_err_t err2 = rd_kafka_metadata(rk, 1, NULL, &metadata, 5000);
        if (err2 != RD_KAFKA_RESP_ERR_NO_ERROR) {
                fprintf(stderr,
                        "%% Failed to acquire metadata: %s\n",
                        rd_kafka_err2str(err2));
        }
        int32_t *replicas = NULL;
        if (metadata->broker_cnt < 1) {
            return -1;
        }
        replicas = malloc(sizeof(*replicas) * metadata->broker_cnt);
        for (int i = 0 ; i < metadata->broker_cnt ; i++)
                    replicas[i] = metadata->brokers[i].id;
        rd_kafka_NewTopic_set_replica_assignment(new_topics[0], 0, replicas, 3, errstr2, sizeof(errstr2));
        // rd_kafka_NewTopic_set_config(new_topics[0], "message.timeout.ms", "1");
        rd_kafka_NewTopic_set_replica_assignment(new_topics[1], 0, replicas, 3, errstr3, sizeof(errstr3));
        // rd_kafka_NewTopic_set_config(new_topics[1], "message.timeout.ms", "1");
        rd_kafka_NewTopic_set_replica_assignment(new_topics[2], 0, replicas, 3, errstr4, sizeof(errstr4));
        // rd_kafka_NewTopic_set_config(new_topics[2], "message.timeout.ms", "1");

        rd_kafka_AdminOptions_t *options = rd_kafka_AdminOptions_new(rk, RD_KAFKA_ADMIN_OP_CREATETOPICS);
        rd_kafka_resp_err_t err = rd_kafka_AdminOptions_set_operation_timeout(options, 100, errstr1, sizeof(errstr1));

        if (err) {
            printf("2.1 %s\n", rd_kafka_err2str(err));
        }
        rd_kafka_queue_t* q = rd_kafka_queue_new(rk);
        rd_kafka_CreateTopics(rk, new_topics, 3, options, q);

        rd_kafka_event_t* rkev = rd_kafka_queue_poll(q, 500);
        printf("3.2 queue size %d\n", rd_kafka_queue_length(q));
        const rd_kafka_CreateTopics_result_t* res = NULL;
        if (rkev) {
            res = rd_kafka_event_CreateTopics_result(rkev);
            printf("4: print res %s, rkev type %s\n", res?"ok":"null", rd_kafka_event_name(rkev));
        }
        if (rkev) {
            rd_kafka_resp_err_t err2 = rd_kafka_event_error(rkev);
            printf("4.1 %s\n",rd_kafka_event_error_string(rkev));
        }
        size_t res_cnt;
        if (res) {
            const rd_kafka_topic_result_t **terr = rd_kafka_CreateTopics_result_topics(res, &res_cnt);
            for (int i = 0; i < res_cnt; i++) {
                const rd_kafka_topic_result_t *ex = terr[i];
                printf("CreateTopics result: #%d: %s: %s: %s\n",
                            i,
                            rd_kafka_topic_result_name(ex),
                            rd_kafka_err2name(rd_kafka_topic_result_error(ex)),
                            rd_kafka_topic_result_error_string(ex)
                );
            }
            
            free(terr);
        }
        /* UNCOMMENT THIS LINE BELOWWILL HELP BUT WHY? */
        //rd_kafka_event_destroy(rkev);
        rd_kafka_NewTopic_destroy_array(new_topics, 3);
        rd_kafka_AdminOptions_destroy(options);
        rd_kafka_queue_destroy(q);
       
        // go on

        topic_conf = rd_kafka_topic_conf_new();

        rd_kafka_topic_t* m_topic = NULL;
        printf("begin to obtain topic\n");
        m_topic = rd_kafka_topic_new(rk, topic_name, topic_conf);
        printf("%s\n", rd_kafka_topic_name(m_topic));
        for (int i = 0; i < 1000; i++) {
            rd_kafka_produce(m_topic, 0, RD_KAFKA_MSG_F_COPY, (void*)"string", 6, NULL, 0, NULL);
            rd_kafka_poll(rk, 0);
        }

IMPORTANT: Always try to reproduce the issue on the latest released version (see https://github.com/edenhill/librdkafka/releases), if it can't be reproduced on the latest version the issue has been fixed.

Checklist

IMPORTANT: We will close issues where the checklist has not been completed.

Please provide the following information:

  • librdkafka version (release number or git tag): librdkafka-1.0.1
  • Apache Kafka version: <REPLACE with e.g., 0.10.2.3>
  • librdkafka client configuration: <REPLACE with e.g., message.timeout.ms=123, auto.reset.offset=earliest, ..>
  • Operating system: <REPLACE with e.g., Centos 5 (x64)>
  • Provide logs (with debug=.. as necessary) from librdkafka
  • Provide broker log excerpts
  • Critical issue
@MockingJayWong
Copy link
Author

-3
-2
%7|1562212202.661|IDEMPSTATE|rdkafka#producer-1| [thrd:main]: Idempotent producer state change Init -> RequestPID
%7|1562212202.661|WAKEUPFD|rdkafka#producer-1| [thrd:app]: vm1:9092/bootstrap: Enabled low-latency ops queue wake-ups
%7|1562212202.661|BRKMAIN|rdkafka#producer-1| [thrd::0/internal]: :0/internal: Enter main broker thread
%7|1562212202.661|BROKER|rdkafka#producer-1| [thrd:app]: vm1:9092/bootstrap: Added new broker with NodeId -1
%7|1562212202.661|CONNECT|rdkafka#producer-1| [thrd:app]: vm1:9092/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s))
%7|1562212202.661|INIT|rdkafka#producer-1| [thrd:app]: librdkafka v1.0.1 (0x10001ff) rdkafka#producer-1 initialized (builtin.features snappy,sasl,regex,lz4,sasl_plain,plugins, GCC GXX INSTALL GNULD LDS LIBDL PLUGINS HDRHISTOGRAM SNAPPY SOCKEM CRC32C_HW, debug 0xffff)
-1
0
1
%7|1562212202.661|CONNECT|rdkafka#producer-1| [thrd:app]: Not selecting any broker for cluster connection: still suppressed for 49ms: application metadata request
%7|1562212202.661|CONNECT|rdkafka#producer-1| [thrd:app]: Not selecting any broker for cluster connection: still suppressed for 49ms: application metadata request
%7|1562212202.661|BRKMAIN|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Enter main broker thread
%7|1562212202.661|CONNECT|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Received CONNECT op
%7|1562212202.661|STATE|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
%7|1562212202.661|BROADCAST|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: Broadcasting state change
%7|1562212202.661|CONNECT|rdkafka#producer-1| [thrd:app]: Not selecting any broker for cluster connection: still suppressed for 49ms: application metadata request
%7|1562212202.661|CONNECT|rdkafka#producer-1| [thrd:app]: Not selecting any broker for cluster connection: still suppressed for 49ms: application metadata request
%7|1562212202.661|CONNECT|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: broker in state TRY_CONNECT connecting
%7|1562212202.661|STATE|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
%7|1562212202.661|BROADCAST|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: Broadcasting state change
%7|1562212202.661|CONNECT|rdkafka#producer-1| [thrd:app]: Not selecting any broker for cluster connection: still suppressed for 49ms: application metadata request
%7|1562212202.661|CONNECT|rdkafka#producer-1| [thrd:app]: Not selecting any broker for cluster connection: still suppressed for 49ms: application metadata request
%7|1562212202.661|CONNECT|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Connecting to ipv4#172.30.19.210:9092 (plaintext) with socket 7
%7|1562212202.664|CONNECT|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Connected to ipv4#172.30.19.210:9092
%7|1562212202.664|CONNECTED|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Connected (#1)
%7|1562212202.664|FEATURE|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1562212202.664|STATE|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY
%7|1562212202.664|BROADCAST|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: Broadcasting state change
%7|1562212202.664|CONNECT|rdkafka#producer-1| [thrd:app]: Not selecting any broker for cluster connection: still suppressed for 46ms: application metadata request
%7|1562212202.664|CONNECT|rdkafka#producer-1| [thrd:app]: Not selecting any broker for cluster connection: still suppressed for 46ms: application metadata request
%7|1562212202.664|SEND|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Sent ApiVersionRequest (v0, 25 bytes @ 0, CorrId 1)
%7|1562212202.666|RECV|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Received ApiVersionResponse (v0, 270 bytes, CorrId 1, rtt 1.72ms)
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Broker API support:
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey Produce (0) Versions 0..7
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey Fetch (1) Versions 0..10
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey Offset (2) Versions 0..5
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey Metadata (3) Versions 0..7
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey LeaderAndIsr (4) Versions 0..2
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey StopReplica (5) Versions 0..1
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey UpdateMetadata (6) Versions 0..5
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey ControlledShutdown (7) Versions 0..2
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey OffsetCommit (8) Versions 0..6
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey OffsetFetch (9) Versions 0..5
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey GroupCoordinator (10) Versions 0..2
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey JoinGroup (11) Versions 0..4
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey Heartbeat (12) Versions 0..2
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey LeaveGroup (13) Versions 0..2
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey SyncGroup (14) Versions 0..2
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey DescribeGroups (15) Versions 0..2
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey ListGroups (16) Versions 0..2
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey SaslHandshake (17) Versions 0..1
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey ApiVersion (18) Versions 0..2
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey CreateTopics (19) Versions 0..3
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey DeleteTopics (20) Versions 0..3
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey DeleteRecords (21) Versions 0..1
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey InitProducerId (22) Versions 0..1
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey OffsetForLeaderEpoch (23) Versions 0..2
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey EndTxn (26) Versions 0..1
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey TxnOffsetCommit (28) Versions 0..2
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey DescribeAcls (29) Versions 0..1
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey CreateAcls (30) Versions 0..1
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey DeleteAcls (31) Versions 0..1
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey DescribeConfigs (32) Versions 0..2
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey AlterConfigs (33) Versions 0..1
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey AlterReplicaLogDirs (34) Versions 0..1
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey DescribeLogDirs (35) Versions 0..1
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey SaslAuthenticate (36) Versions 0..1
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey CreatePartitions (37) Versions 0..1
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey CreateDelegationToken (38) Versions 0..1
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey RenewDelegationToken (39) Versions 0..1
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey ExpireDelegationToken (40) Versions 0..1
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey DescribeDelegationToken (41) Versions 0..1
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey DeleteGroups (42) Versions 0..1
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: ApiKey Unknown-43? (43) Versions 0..0
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Feature MsgVer1: Produce (2..2) supported by broker
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Feature MsgVer1: Fetch (2..2) supported by broker
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Enabling feature MsgVer1
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Feature MsgVer2: Produce (3..3) supported by broker
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Feature MsgVer2: Fetch (4..4) supported by broker
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Enabling feature MsgVer2
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Enabling feature ApiVersion
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Feature BrokerGroupCoordinator: GroupCoordinator (0..0) supported by broker
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Enabling feature BrokerGroupCoordinator
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Feature BrokerBalancedConsumer: GroupCoordinator (0..0) supported by broker
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Enabling feature BrokerBalancedConsumer
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Feature ThrottleTime: Produce (1..2) supported by broker
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1562212202.666|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Enabling feature ThrottleTime
%7|1562212202.667|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Feature Sasl: JoinGroup (0..0) supported by broker
%7|1562212202.667|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Enabling feature Sasl
%7|1562212202.667|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1562212202.667|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Enabling feature SaslHandshake
%7|1562212202.667|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Feature LZ4: GroupCoordinator (0..0) supported by broker
%7|1562212202.667|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Enabling feature LZ4
%7|1562212202.667|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Feature OffsetTime: Offset (1..1) supported by broker
%7|1562212202.667|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Enabling feature OffsetTime
%7|1562212202.667|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Feature IdempotentProducer: InitProducerId (0..0) supported by broker
%7|1562212202.667|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Enabling feature IdempotentProducer
%7|1562212202.667|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Feature ZSTD: Produce (7..7) supported by broker
%7|1562212202.667|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Feature ZSTD: Fetch (10..10) supported by broker
%7|1562212202.667|APIVERSION|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Enabling feature ZSTD
%7|1562212202.667|FEATURE|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD
%7|1562212202.667|STATE|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Broker changed state APIVERSION_QUERY -> UP
%7|1562212202.667|BROADCAST|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: Broadcasting state change
%7|1562212202.667|METADATA|rdkafka#producer-1| [thrd:app]: vm1:9092/bootstrap: Request metadata for all topics: application requested
%7|1562212202.667|METADATA|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Request metadata for brokers only: connected
%7|1562212202.667|SEND|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Sent MetadataRequest (v2, 25 bytes @ 0, CorrId 2)
%7|1562212202.667|SEND|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Sent MetadataRequest (v2, 25 bytes @ 0, CorrId 3)
%7|1562212202.668|RECV|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: Received MetadataResponse (v2, 81 bytes, CorrId 2, rtt 1.54ms)
%7|1562212202.668|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/bootstrap: ===== Received metadata: connected =====
%7|1562212202.668|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/bootstrap: ClusterId: FVuAdeTHRJ64dKBZv7IQmg, ControllerId: 0
%7|1562212202.668|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/bootstrap: 3 brokers, 0 topics
%7|1562212202.668|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/bootstrap: Broker #0/3: vm1:9092 NodeId 0
%7|1562212202.668|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/bootstrap: Broker #1/3: vm3:9092 NodeId 2
%7|1562212202.668|WAKEUPFD|rdkafka#producer-1| [thrd:main]: vm3:9092/2: Enabled low-latency ops queue wake-ups
%7|1562212202.668|BROKER|rdkafka#producer-1| [thrd:main]: vm3:9092/2: Added new broker with NodeId 2
%7|1562212202.668|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/bootstrap: Broker #2/3: vm2:9092 NodeId 1
%7|1562212202.668|WAKEUPFD|rdkafka#producer-1| [thrd:main]: vm2:9092/1: Enabled low-latency ops queue wake-ups
%7|1562212202.668|BROKER|rdkafka#producer-1| [thrd:main]: vm2:9092/1: Added new broker with NodeId 1
%7|1562212202.668|CLUSTERID|rdkafka#producer-1| [thrd:main]: vm1:9092/bootstrap: ClusterId update "" -> "FVuAdeTHRJ64dKBZv7IQmg"
%7|1562212202.668|CONTROLLERID|rdkafka#producer-1| [thrd:main]: vm1:9092/bootstrap: ControllerId update -1 -> 0
%7|1562212202.668|BROADCAST|rdkafka#producer-1| [thrd:main]: Broadcasting state change
%7|1562212202.668|UPDATE|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/bootstrap: NodeId changed from -1 to 0
%7|1562212202.668|UPDATE|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/0: Name changed from vm1:9092/bootstrap to vm1:9092/0
%7|1562212202.668|LEADER|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/0: Mapped 0 partition(s) to broker
%7|1562212202.668|STATE|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/0: Broker changed state UP -> UPDATE
%7|1562212202.669|BROADCAST|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: Broadcasting state change
%7|1562212202.669|BROADCAST|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: Broadcasting state change
%7|1562212202.669|STATE|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/0: Broker changed state UPDATE -> UP
%7|1562212202.669|BROADCAST|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: Broadcasting state change
%7|1562212202.669|GETPID|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Acquiring ProducerId: metadata update
%7|1562212202.669|IDEMPSTATE|rdkafka#producer-1| [thrd:main]: Idempotent producer state change RequestPID -> WaitPID
%7|1562212202.669|SEND|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/0: Sent InitProducerIdRequest (v1, 27 bytes @ 0, CorrId 4)
%7|1562212202.669|BRKMAIN|rdkafka#producer-1| [thrd:vm3:9092/2]: vm3:9092/2: Enter main broker thread
%7|1562212202.669|BRKMAIN|rdkafka#producer-1| [thrd:vm2:9092/1]: vm2:9092/1: Enter main broker thread
%7|1562212202.717|RECV|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/0: Received MetadataResponse (v2, 9101 bytes, CorrId 3, rtt 49.87ms)
%7|1562212202.717|RECV|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/0: Received InitProducerIdResponse (v1, 16 bytes, CorrId 4, rtt 48.09ms)
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: ===== Received metadata: application requested =====
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: ClusterId: FVuAdeTHRJ64dKBZv7IQmg, ControllerId: 0
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: 3 brokers, 121 topics
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Broker #0/3: vm1:9092 NodeId 0
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Broker #1/3: vm3:9092 NodeId 2
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Broker #2/3: vm2:9092 NodeId 1
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #0/121: test_timeout23_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #1/121: test_timeout5_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #2/121: test_timeout27_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #3/121: test_timeout26_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #4/121: test_timeout1_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #5/121: test_timeout13_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #6/121: test_timeout18_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #7/121: test_timeout23_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #8/121: test_timeout21_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #9/121: test_timeout38_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #10/121: test_timeout8_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #11/121: test with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #12/121: test_timeout3_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #13/121: test_timeout30_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #14/121: test_timeout19_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #15/121: test_timeout29_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #16/121: test_timeout11_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #17/121: test_timeout22_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #18/121: test_timeout26_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #19/121: test25 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #20/121: test_timeout33_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #21/121: test_timeout4_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #22/121: test_timeout13_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #23/121: test_timeout35_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #24/121: test_timeout1_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #25/121: test1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #26/121: wahaha2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #27/121: test_timeout35_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #28/121: test_timeout17_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #29/121: test_timeout6_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #30/121: test_timeout39_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #31/121: test_timeout16_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #32/121: test_timeout25_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #33/121: test_timeout36_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #34/121: test_timeout15_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #35/121: test_timeout20_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #36/121: _test_global_producer_topic with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #37/121: test_timeout14_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #38/121: test_timeout22_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #39/121: test_timeout20_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #40/121: test_timeout7_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #41/121: test15 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #42/121: test_timeout38_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #43/121: test_timeout21_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #44/121: test_timeout32_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #45/121: test_timeout29_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #46/121: test_timeout34_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #47/121: test_timeout3_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #48/121: test_timeout36_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #49/121: test_timeout24_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #50/121: tesdt with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #51/121: test_timeout26_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #52/121: wahaha with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #53/121: test_timeout17_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #54/121: test_timeout30_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #55/121: hahuhu with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #56/121: test_timeout14_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #57/121: test_timeout6_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #58/121: test_timeout12_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #59/121: test_timeout37_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #60/121: test_timeout16_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #61/121: wahahu2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #62/121: __consumer_offsets with 50 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #63/121: test_timeout39_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #64/121: test_timeout22_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #65/121: test_timeout32_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #66/121: test_timeout24_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #67/121: _test_global_producer_topic_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #68/121: test_timeout28_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #69/121: _test_simple_producer_topic with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #70/121: test_timeout12_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #71/121: test_timeout18_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #72/121: test_timeout34_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #73/121: test_timeout21_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #74/121: test_timeout8_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #75/121: test_timeout11_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #76/121: test_timeout19_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #77/121: test_timeout7_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #78/121: test_timeout30_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #79/121: test_timeout14_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #80/121: test_timeout12_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #81/121: test_timeout3_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #82/121: test_timeout34_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #83/121: test_timeout4_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #84/121: test_timeout15_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #85/121: test_timeout33_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #86/121: test_timeout5_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #87/121: test_timeout24_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #88/121: test35 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #89/121: test_timeout11_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #90/121: test_timeout29_3 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #91/121: test_timeout9_2 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #92/121: test_timeout6_1 with 1 partitions
%7|1562212202.717|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #93/121: test_timeout36_1 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #94/121: test_timeout18_2 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #95/121: test_timeout23_1 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #96/121: test_timeout28_2 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #97/121: test_timeout27_1 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #98/121: test_timeout35_3 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #99/121: test_timeout28_1 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #100/121: test_timeout13_3 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #101/121: test_timeout7_1 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #102/121: test_timeout32_1 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #103/121: test_timeout25_3 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #104/121: test_timeout8_2 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #105/121: test_timeout31_1 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #106/121: test_timeout19_2 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #107/121: test_timeout16_3 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #108/121: test_timeout9_1 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #109/121: test_timeout1_2 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #110/121: test_timeout25_2 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #111/121: test_timeout33_2 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #112/121: test_timeout4_2 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #113/121: test_timeout15_2 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #114/121: test_timeout9_3 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #115/121: test_timeout39_1 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #116/121: test_timeout5_3 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #117/121: test_timeout38_3 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #118/121: test_timeout20_3 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #119/121: test_timeout17_1 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Topic #120/121: test_timeout27_2 with 1 partitions
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: Absolute update of metadata cache with 121 topic(s)
%7|1562212202.718|METADATA|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Caching full metadata with 3 broker(s) and 121 topic(s): application requested
%7|1562212202.718|GETPID|rdkafka#producer-1| [thrd:main]: Acquired PID{Id:3140,Epoch:0}
%7|1562212202.718|IDEMPSTATE|rdkafka#producer-1| [thrd:main]: Idempotent producer state change WaitPID -> Assigned
%7|1562212202.718|WAKEUP|rdkafka#producer-1| [thrd:main]: vm2:9092/1: Wake-up
%7|1562212202.718|WAKEUP|rdkafka#producer-1| [thrd:main]: vm3:9092/2: Wake-up
%7|1562212202.718|WAKEUP|rdkafka#producer-1| [thrd:main]: vm1:9092/0: Wake-up
2
3
3.1 queue size 0
%7|1562212202.718|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state initializing: Success
%7|1562212202.718|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: looking up controller
%7|1562212202.718|ADMIN|rdkafka#producer-1| [thrd:main]: CREATETOPICS: controller vm1:9092/0
%7|1562212202.718|SEND|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/0: Sent CreateTopicsRequest (v2, 186 bytes @ 0, CorrId 5)
%7|1562212202.900|RECV|rdkafka#producer-1| [thrd:vm1:9092/bootstrap]: vm1:9092/0: Received CreateTopicsResponse (v2, 74 bytes, CorrId 5, rtt 182.36ms)
%7|1562212202.901|CREATETOPICS|rdkafka#producer-1| [thrd:main]: CREATETOPICS worker called in state waiting for response from broker: Success
3.2 queue size 0
4: print res ok, rkev type CreateTopicsResult
4.1 Success
CreateTopics result: #0: test_timeout40_1: NO_ERROR: (null)
CreateTopics result: #1: test_timeout40_2: NO_ERROR: (null)
CreateTopics result: #2: test_timeout40_3: NO_ERROR: (null)
begin to obtain topic
%7|1562212202.906|TOPIC|rdkafka#producer-1| [thrd:app]: New local topic: test_timeout40_1
%7|1562212202.906|TOPPARNEW|rdkafka#producer-1| [thrd:app]: NEW test_timeout40_1 [-1] 0x56025afedb70 (at rd_kafka_topic_new0:393)
%7|1562212202.906|METADATA|rdkafka#producer-1| [thrd:app]: Hinted cache of 1/1 topic(s) being queried
%7|1562212202.906|METADATA|rdkafka#producer-1| [thrd:app]: Requesting metadata for 1/1 topics: leader query
Segmentation fault (core dumped)

@edenhill
Copy link
Contributor

edenhill commented Jul 9, 2019

This free should not be there:
free(terr);

@MockingJayWong
Copy link
Author

MockingJayWong commented Jul 9, 2019 •
edited
Loading

sorry to make a big mistake here, and really appreciate
(: uncomment the line and everything works.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
2 participants
@edenhill @MockingJayWong