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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
|
# Description:
# Kafka C/C++ (librdkafka) client library
licenses(["notice"]) # 2-clause BSD license
exports_files(["LICENSE"])
cc_library(
name = "kafka",
srcs = [
"config.h",
"src-cpp/ConfImpl.cpp",
"src-cpp/ConsumerImpl.cpp",
"src-cpp/HandleImpl.cpp",
"src-cpp/KafkaConsumerImpl.cpp",
"src-cpp/MessageImpl.cpp",
"src-cpp/MetadataImpl.cpp",
"src-cpp/ProducerImpl.cpp",
"src-cpp/QueueImpl.cpp",
"src-cpp/RdKafka.cpp",
"src-cpp/TopicImpl.cpp",
"src-cpp/TopicPartitionImpl.cpp",
"src/crc32c.c",
"src/crc32c.h",
"src/lz4.c",
"src/lz4.h",
"src/lz4frame.c",
"src/lz4frame.h",
"src/lz4frame_static.h",
"src/lz4hc.c",
"src/lz4hc.h",
"src/lz4opt.h",
"src/queue.h",
"src/rd.h",
"src/rdaddr.c",
"src/rdaddr.h",
"src/rdatomic.h",
"src/rdavg.h",
"src/rdavl.c",
"src/rdavl.h",
"src/rdbuf.c",
"src/rdbuf.h",
"src/rdcrc32.h",
"src/rddl.h",
"src/rdendian.h",
"src/rdgz.c",
"src/rdgz.h",
"src/rdinterval.h",
"src/rdkafka.c",
"src/rdkafka.h",
"src/rdkafka_admin.c",
"src/rdkafka_admin.h",
"src/rdkafka_assignor.c",
"src/rdkafka_assignor.h",
"src/rdkafka_aux.c",
"src/rdkafka_aux.h",
"src/rdkafka_background.c",
"src/rdkafka_broker.c",
"src/rdkafka_broker.h",
"src/rdkafka_buf.c",
"src/rdkafka_buf.h",
"src/rdkafka_cgrp.c",
"src/rdkafka_cgrp.h",
"src/rdkafka_conf.c",
"src/rdkafka_conf.h",
"src/rdkafka_confval.h",
"src/rdkafka_event.h",
"src/rdkafka_feature.c",
"src/rdkafka_feature.h",
"src/rdkafka_header.c",
"src/rdkafka_header.h",
"src/rdkafka_int.h",
"src/rdkafka_interceptor.c",
"src/rdkafka_interceptor.h",
"src/rdkafka_lz4.c",
"src/rdkafka_lz4.h",
"src/rdkafka_metadata.c",
"src/rdkafka_metadata.h",
"src/rdkafka_metadata_cache.c",
"src/rdkafka_msg.c",
"src/rdkafka_msg.h",
"src/rdkafka_msgset.h",
"src/rdkafka_msgset_reader.c",
"src/rdkafka_msgset_writer.c",
"src/rdkafka_offset.c",
"src/rdkafka_offset.h",
"src/rdkafka_op.c",
"src/rdkafka_op.h",
"src/rdkafka_partition.c",
"src/rdkafka_partition.h",
"src/rdkafka_pattern.c",
"src/rdkafka_pattern.h",
"src/rdkafka_proto.h",
"src/rdkafka_queue.c",
"src/rdkafka_queue.h",
"src/rdkafka_range_assignor.c",
"src/rdkafka_request.c",
"src/rdkafka_request.h",
"src/rdkafka_roundrobin_assignor.c",
"src/rdkafka_sasl.c",
"src/rdkafka_sasl.h",
"src/rdkafka_sasl_int.h",
"src/rdkafka_sasl_plain.c",
"src/rdkafka_subscription.c",
"src/rdkafka_timer.c",
"src/rdkafka_timer.h",
"src/rdkafka_topic.c",
"src/rdkafka_topic.h",
"src/rdkafka_transport.c",
"src/rdkafka_transport.h",
"src/rdkafka_transport_int.h",
"src/rdlist.c",
"src/rdlist.h",
"src/rdlog.c",
"src/rdlog.h",
"src/rdmurmur2.c",
"src/rdmurmur2.h",
"src/rdports.c",
"src/rdports.h",
"src/rdposix.h",
"src/rdrand.c",
"src/rdrand.h",
"src/rdregex.c",
"src/rdregex.h",
"src/rdstring.c",
"src/rdstring.h",
"src/rdsysqueue.h",
"src/rdtime.h",
"src/rdtypes.h",
"src/rdunittest.c",
"src/rdunittest.h",
"src/rdvarint.c",
"src/rdvarint.h",
"src/snappy.c",
"src/snappy.h",
"src/tinycthread.c",
"src/tinycthread.h",
"src/xxhash.c",
"src/xxhash.h",
] + select({
"@org_tensorflow//tensorflow:windows": [
"src/rdkafka_sasl_win32.c",
"src/rdwin32.h",
"src/regexp.c",
"src/regexp.h",
],
"//conditions:default": [],
}),
hdrs = [
"config.h",
"src-cpp/rdkafkacpp.h",
"src-cpp/rdkafkacpp_int.h",
"src/lz4.c",
"src/snappy_compat.h",
],
copts = select({
"@org_tensorflow//tensorflow:windows": [
"-DWIN32_LEAN_AND_MEAN",
"-DWITHOUT_WIN32_CONFIG",
"-DWITH_ZLIB=1",
"-DWITH_SSL=1",
"-DWITH_SNAPPY=1",
],
"//conditions:default": [],
}),
defines = ["LIBRDKAFKA_STATICLIB"],
includes = [
"src",
"src-cpp",
],
linkopts = select({
"@org_tensorflow//tensorflow:windows": ["-defaultlib:crypt32.lib"],
"//conditions:default": ["-lpthread"],
}),
visibility = ["//visibility:public"],
deps = [
"@boringssl//:ssl",
"@zlib_archive//:zlib",
],
)
|
