• 大小: 3.92MB
    文件类型: .zip
    金币: 1
    下载: 0 次
    发布日期: 2023-09-20
  • 语言: 其他
  • 标签: librdkafka  

资源简介

libkafka 2015编译库

资源截图

代码片段和文件信息

/*
 * librdkafka - Apache Kafka C library
 *
 * Copyright (c) 2012-2013 Magnus Edenhill
 * All rights reserved.
 * 
 * Redistribution and use in source and binary forms with or without
 * modification are permitted provided that the following conditions are met: 
 * 
 * 1. Redistributions of source code must retain the above copyright notice
 *    this list of conditions and the following disclaimer. 
 * 2. Redistributions in binary form must reproduce the above copyright notice
 *    this list of conditions and the following disclaimer in the documentation
 *    and/or other materials provided with the distribution. 
 * 
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS “AS IS“
 * AND ANY EXPRESS OR IMPLIED WARRANTIES INCLUDING BUT NOT LIMITED TO THE 
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 
 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE 
 * LIABLE FOR ANY DIRECT INDIRECT INCIDENTAL SPECIAL EXEMPLARY OR 
 * CONSEQUENTIAL DAMAGES (INCLUDING BUT NOT LIMITED TO PROCUREMENT OF 
 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE DATA OR PROFITS; OR BUSINESS 
 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY WHETHER IN 
 * CONTRACT STRICT LIABILITY OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE EVEN IF ADVISED OF THE
 * POSSIBILITY OF SUCH DAMAGE.
 */


#define _GNU_SOURCE
#include 
#include 
#include 
#include 
#include 
#include 

#include “rdkafka_int.h“
#include “rdkafka_msg.h“
#include “rdkafka_broker.h“
#include “rdkafka_topic.h“
#include “rdkafka_partition.h“
#include “rdkafka_offset.h“
#include “rdkafka_transport.h“
#include “rdkafka_cgrp.h“
#include “rdkafka_assignor.h“
#include “rdkafka_request.h“
#include “rdkafka_event.h“
#include “rdkafka_sasl.h“
#include “rdkafka_interceptor.h“

#include “rdtime.h“
#include “crc32c.h“
#include “rdunittest.h“

#ifdef _MSC_VER
#include 
#include 
#endif



static once_flag rd_kafka_global_init_once = ONCE_FLAG_INIT;

/**
 * @brief Global counter+lock for all active librdkafka instances
 */
mtx_t rd_kafka_global_lock;
int rd_kafka_global_cnt;


/**
 * Last API error code per thread.
 * Shared among all rd_kafka_t instances.
 */
rd_kafka_resp_err_t RD_TLS rd_kafka_last_error_code;


/**
 * Current number of threads created by rdkafka.
 * This is used in regression tests.
 */
rd_atomic32_t rd_kafka_thread_cnt_curr;
int rd_kafka_thread_cnt (void) {
#if ENABLE_SHAREDPTR_DEBUG
        rd_shared_ptrs_dump();
#endif

return rd_atomic32_get(&rd_kafka_thread_cnt_curr);
}

/**
 * Current thread‘s log name (TLS)
 */
static char RD_TLS rd_kafka_thread_name[64] = “app“;

void rd_kafka_set_thread_name (const char *fmt ...) {
        va_list ap;

        va_start(ap fmt);
        rd_vsnprintf(rd_kafka_thread_name sizeof(rd_kafka_thread_name)
                     fmt

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----
     目录           0  2018-05-15 15:04  Release\
     文件     1179648  2015-11-30 13:46  Release\libeay32.dll
     文件      518144  2018-05-14 18:31  Release\librdkafka.dll
     文件       26575  2018-05-14 18:31  Release\librdkafka.exp
     文件       45144  2018-05-14 18:31  Release\librdkafka.lib
     文件     2609152  2018-05-14 18:31  Release\librdkafka.pdb
     文件       60416  2018-05-15 08:21  Release\librdkafkacpp.dll
     文件       22776  2018-05-15 08:21  Release\librdkafkacpp.exp
     文件       37232  2018-05-15 08:21  Release\librdkafkacpp.lib
     文件     1290240  2018-05-15 08:21  Release\librdkafkacpp.pdb
     文件      116243  2018-04-18 16:59  Release\rdkafka.c
     文件      139813  2018-04-18 16:59  Release\rdkafka.h
     文件       73400  2018-04-18 16:59  Release\rdkafkacpp.h
     文件       41472  2018-05-15 13:48  Release\rdkafka_consumer_example_cpp.exe
     文件     2723840  2018-05-15 13:48  Release\rdkafka_consumer_example_cpp.pdb
     文件       34816  2018-05-15 13:51  Release\rdkafka_example.exe
     文件      962560  2018-05-15 13:51  Release\rdkafka_example.pdb
     文件       36864  2018-05-15 13:51  Release\rdkafka_performance.exe
     文件      593920  2018-05-15 13:51  Release\rdkafka_performance.pdb
     文件      274432  2015-11-30 13:46  Release\ssleay32.dll
     文件      614912  2018-05-15 13:51  Release\tests.exe
     文件     2617344  2018-05-15 13:51  Release\tests.pdb
     文件       70144  2015-05-15 17:18  Release\zlib.dll

评论

共有 条评论

相关资源