search

confluentinc / librdkafka

The Apache Kafka C/C++ library
Other
204 stars 3.14k forks source link

rd_kafka_topic_new after using admin api #2399

Closed MockingJayWong closed 5 years ago

MockingJayWong commented 5 years ago

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

Description

environment

librdkafka version

step in follow

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:

MockingJayWong commented 5 years ago

-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 commented 5 years ago

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

MockingJayWong commented 5 years ago

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