1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
|
#include <librdkafka/rdkafka.h>
rd_kafka_conf_t *rd_kafka_conf_new(void)
{
return NULL;
}
rd_kafka_conf_res_t rd_kafka_conf_set(rd_kafka_conf_t *conf, const char *name, const char *value, char *errstr, size_t errstr_size)
{
return RD_KAFKA_CONF_OK;
}
rd_kafka_t *rd_kafka_new(rd_kafka_type_t type, rd_kafka_conf_t *conf, char *errstr, size_t errstr_size)
{
return NULL;
}
rd_kafka_topic_t *rd_kafka_topic_new(rd_kafka_t *rk, const char *topic, rd_kafka_topic_conf_t *conf)
{
return NULL;
}
int rd_kafka_produce(rd_kafka_topic_t *rkt, int32_t partition, int msgflags, void *payload, size_t len, const void *key, size_t keylen, void *msg_opaque)
{
return 0;
}
rd_kafka_resp_err_t rd_kafka_last_error (void)
{
return RD_KAFKA_RESP_ERR_NO_ERROR;
}
const char *rd_kafka_err2name (rd_kafka_resp_err_t err)
{
return NULL;
}
const char *rd_kafka_err2str (rd_kafka_resp_err_t err)
{
return NULL;
}
int rd_kafka_brokers_add(rd_kafka_t *rk, const char *brokerlist)
{
return 1;
}
|
