-
大小: 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
- 上一篇:ArcGIS二次开发编程
- 下一篇:软件工程课程设计-银行ATM系统
评论
共有 条评论