MINIFICPP-512 - upgrade to librdkafka 0.11.4 This closes #345.
Signed-off-by: Marc Parisi <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/commit/7528d23e Tree: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/tree/7528d23e Diff: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/diff/7528d23e Branch: refs/heads/master Commit: 7528d23eecd0dc83b97a35f3e699804d25bf842d Parents: bc6d2a1 Author: Dustin Rodrigues <[email protected]> Authored: Sat May 26 18:34:31 2018 -0400 Committer: Marc Parisi <[email protected]> Committed: Wed Jun 6 10:13:56 2018 -0400 ---------------------------------------------------------------------- CMakeLists.txt | 2 +- libminifi/test/kafka-tests/CMakeLists.txt | 4 +- thirdparty/librdkafka-0.11.1/.appveyor.yml | 88 - thirdparty/librdkafka-0.11.1/.dir-locals.el | 3 - thirdparty/librdkafka-0.11.1/.doozer.json | 88 - .../librdkafka-0.11.1/.github/ISSUE_TEMPLATE | 26 - thirdparty/librdkafka-0.11.1/.gitignore | 29 - thirdparty/librdkafka-0.11.1/.travis.yml | 41 - thirdparty/librdkafka-0.11.1/CMakeLists.txt | 168 - thirdparty/librdkafka-0.11.1/CONFIGURATION.md | 128 - thirdparty/librdkafka-0.11.1/CONTRIBUTING.md | 271 -- thirdparty/librdkafka-0.11.1/Doxyfile | 2385 ---------- thirdparty/librdkafka-0.11.1/INTRODUCTION.md | 566 --- thirdparty/librdkafka-0.11.1/LICENSE | 25 - thirdparty/librdkafka-0.11.1/LICENSE.crc32c | 28 - thirdparty/librdkafka-0.11.1/LICENSE.lz4 | 26 - thirdparty/librdkafka-0.11.1/LICENSE.pycrc | 23 - thirdparty/librdkafka-0.11.1/LICENSE.queue | 31 - thirdparty/librdkafka-0.11.1/LICENSE.regexp | 5 - thirdparty/librdkafka-0.11.1/LICENSE.snappy | 36 - .../librdkafka-0.11.1/LICENSE.tinycthread | 26 - thirdparty/librdkafka-0.11.1/LICENSE.wingetopt | 49 - thirdparty/librdkafka-0.11.1/LICENSES.txt | 284 -- thirdparty/librdkafka-0.11.1/Makefile | 68 - thirdparty/librdkafka-0.11.1/README.md | 160 - thirdparty/librdkafka-0.11.1/README.win32 | 28 - thirdparty/librdkafka-0.11.1/config.h.in | 39 - thirdparty/librdkafka-0.11.1/configure | 214 - .../librdkafka-0.11.1/configure.librdkafka | 204 - thirdparty/librdkafka-0.11.1/dev-conf.sh | 15 - .../librdkafka-0.11.1/examples/.gitignore | 7 - .../librdkafka-0.11.1/examples/CMakeLists.txt | 20 - thirdparty/librdkafka-0.11.1/examples/Makefile | 92 - .../librdkafka-0.11.1/examples/globals.json | 11 - .../examples/kafkatest_verifiable_client.cpp | 934 ---- .../examples/rdkafka_consumer_example.c | 624 --- .../examples/rdkafka_consumer_example.cpp | 485 -- .../examples/rdkafka_example.c | 806 ---- .../examples/rdkafka_example.cpp | 645 --- .../examples/rdkafka_performance.c | 1561 ------- .../examples/rdkafka_simple_producer.c | 260 -- .../examples/rdkafka_zookeeper_example.c | 728 --- thirdparty/librdkafka-0.11.1/lds-gen.py | 38 - thirdparty/librdkafka-0.11.1/mainpage.doxy | 35 - .../librdkafka-0.11.1/mklove/Makefile.base | 193 - .../mklove/modules/configure.atomics | 144 - .../mklove/modules/configure.base | 1772 -------- .../mklove/modules/configure.builtin | 62 - .../mklove/modules/configure.cc | 178 - .../mklove/modules/configure.cxx | 8 - .../mklove/modules/configure.fileversion | 65 - .../mklove/modules/configure.gitversion | 19 - .../mklove/modules/configure.good_cflags | 18 - .../mklove/modules/configure.host | 110 - .../mklove/modules/configure.lib | 49 - .../mklove/modules/configure.parseversion | 95 - .../mklove/modules/configure.pic | 16 - .../mklove/modules/configure.socket | 20 - .../librdkafka-0.11.1/packaging/RELEASE.md | 116 - .../packaging/archlinux/PKGBUILD | 5 - .../packaging/cmake/Config.cmake.in | 20 - .../cmake/try_compile/atomic_32_test.c | 8 - .../cmake/try_compile/atomic_64_test.c | 8 - .../cmake/try_compile/rdkafka_setup.cmake | 76 - .../packaging/cmake/try_compile/regex_test.c | 10 - .../packaging/cmake/try_compile/strndup_test.c | 5 - .../packaging/cmake/try_compile/sync_32_test.c | 8 - .../packaging/cmake/try_compile/sync_64_test.c | 8 - .../packaging/debian/.gitignore | 6 - .../packaging/debian/changelog | 66 - .../librdkafka-0.11.1/packaging/debian/compat | 1 - .../librdkafka-0.11.1/packaging/debian/control | 49 - .../packaging/debian/copyright | 84 - .../librdkafka-0.11.1/packaging/debian/docs | 3 - .../librdkafka-0.11.1/packaging/debian/gbp.conf | 9 - .../packaging/debian/librdkafka-dev.dirs | 2 - .../packaging/debian/librdkafka-dev.examples | 2 - .../packaging/debian/librdkafka-dev.install | 6 - .../packaging/debian/librdkafka-dev.substvars | 1 - .../packaging/debian/librdkafka.dsc | 16 - .../packaging/debian/librdkafka1-dbg.substvars | 1 - .../packaging/debian/librdkafka1.dirs | 1 - .../packaging/debian/librdkafka1.install | 2 - .../debian/librdkafka1.postinst.debhelper | 5 - .../debian/librdkafka1.postrm.debhelper | 5 - .../packaging/debian/librdkafka1.symbols | 64 - .../librdkafka-0.11.1/packaging/debian/rules | 17 - .../packaging/debian/source/format | 1 - .../librdkafka-0.11.1/packaging/debian/watch | 2 - .../librdkafka-0.11.1/packaging/get_version.py | 21 - .../packaging/homebrew/README.md | 15 - .../packaging/homebrew/brew-update-pr.sh | 31 - .../packaging/nuget/.gitignore | 5 - .../librdkafka-0.11.1/packaging/nuget/README.md | 50 - .../packaging/nuget/artifact.py | 173 - .../librdkafka-0.11.1/packaging/nuget/nuget.sh | 21 - .../packaging/nuget/packaging.py | 596 --- .../packaging/nuget/release.py | 91 - .../packaging/nuget/requirements.txt | 2 - .../nuget/templates/librdkafka.redist.nuspec | 21 - .../nuget/templates/librdkafka.redist.props | 18 - .../nuget/templates/librdkafka.redist.targets | 19 - .../packaging/nuget/zfile/__init__.py | 0 .../packaging/nuget/zfile/zfile.py | 100 - .../librdkafka-0.11.1/packaging/rpm/.gitignore | 3 - .../librdkafka-0.11.1/packaging/rpm/Makefile | 79 - .../packaging/rpm/el7-x86_64.cfg | 40 - .../packaging/rpm/librdkafka.spec | 103 - .../librdkafka-0.11.1/src-cpp/CMakeLists.txt | 33 - .../librdkafka-0.11.1/src-cpp/ConfImpl.cpp | 89 - .../librdkafka-0.11.1/src-cpp/ConsumerImpl.cpp | 233 - .../librdkafka-0.11.1/src-cpp/HandleImpl.cpp | 365 -- .../src-cpp/KafkaConsumerImpl.cpp | 257 -- thirdparty/librdkafka-0.11.1/src-cpp/Makefile | 58 - .../librdkafka-0.11.1/src-cpp/MessageImpl.cpp | 38 - .../librdkafka-0.11.1/src-cpp/MetadataImpl.cpp | 151 - .../librdkafka-0.11.1/src-cpp/ProducerImpl.cpp | 167 - .../librdkafka-0.11.1/src-cpp/QueueImpl.cpp | 66 - thirdparty/librdkafka-0.11.1/src-cpp/README.md | 16 - .../librdkafka-0.11.1/src-cpp/RdKafka.cpp | 52 - .../librdkafka-0.11.1/src-cpp/TopicImpl.cpp | 124 - .../src-cpp/TopicPartitionImpl.cpp | 55 - .../librdkafka-0.11.1/src-cpp/rdkafkacpp.h | 2190 --------- .../librdkafka-0.11.1/src-cpp/rdkafkacpp_int.h | 897 ---- thirdparty/librdkafka-0.11.1/src/CMakeLists.txt | 128 - thirdparty/librdkafka-0.11.1/src/Makefile | 81 - thirdparty/librdkafka-0.11.1/src/crc32c.c | 427 -- thirdparty/librdkafka-0.11.1/src/crc32c.h | 35 - .../src/librdkafka_cgrp_synch.png | Bin 93796 -> 0 bytes thirdparty/librdkafka-0.11.1/src/lz4.c | 1462 ------ thirdparty/librdkafka-0.11.1/src/lz4.h | 463 -- thirdparty/librdkafka-0.11.1/src/lz4frame.c | 1440 ------ thirdparty/librdkafka-0.11.1/src/lz4frame.h | 367 -- .../librdkafka-0.11.1/src/lz4frame_static.h | 98 - thirdparty/librdkafka-0.11.1/src/lz4hc.c | 786 ---- thirdparty/librdkafka-0.11.1/src/lz4hc.h | 269 -- thirdparty/librdkafka-0.11.1/src/lz4opt.h | 360 -- thirdparty/librdkafka-0.11.1/src/queue.h | 850 ---- thirdparty/librdkafka-0.11.1/src/rd.h | 455 -- thirdparty/librdkafka-0.11.1/src/rdaddr.c | 220 - thirdparty/librdkafka-0.11.1/src/rdaddr.h | 184 - thirdparty/librdkafka-0.11.1/src/rdatomic.h | 188 - thirdparty/librdkafka-0.11.1/src/rdavg.h | 95 - thirdparty/librdkafka-0.11.1/src/rdavl.c | 214 - thirdparty/librdkafka-0.11.1/src/rdavl.h | 253 -- thirdparty/librdkafka-0.11.1/src/rdbuf.c | 1547 ------- thirdparty/librdkafka-0.11.1/src/rdbuf.h | 325 -- thirdparty/librdkafka-0.11.1/src/rdcrc32.c | 113 - thirdparty/librdkafka-0.11.1/src/rdcrc32.h | 146 - thirdparty/librdkafka-0.11.1/src/rddl.c | 179 - thirdparty/librdkafka-0.11.1/src/rddl.h | 41 - thirdparty/librdkafka-0.11.1/src/rdendian.h | 151 - thirdparty/librdkafka-0.11.1/src/rdgz.c | 124 - thirdparty/librdkafka-0.11.1/src/rdgz.h | 42 - thirdparty/librdkafka-0.11.1/src/rdinterval.h | 116 - thirdparty/librdkafka-0.11.1/src/rdkafka.c | 3392 -------------- thirdparty/librdkafka-0.11.1/src/rdkafka.h | 3820 ---------------- .../librdkafka-0.11.1/src/rdkafka_assignor.c | 551 --- .../librdkafka-0.11.1/src/rdkafka_assignor.h | 159 - .../librdkafka-0.11.1/src/rdkafka_broker.c | 3797 ---------------- .../librdkafka-0.11.1/src/rdkafka_broker.h | 328 -- thirdparty/librdkafka-0.11.1/src/rdkafka_buf.c | 428 -- thirdparty/librdkafka-0.11.1/src/rdkafka_buf.h | 819 ---- thirdparty/librdkafka-0.11.1/src/rdkafka_cgrp.c | 3204 ------------- thirdparty/librdkafka-0.11.1/src/rdkafka_cgrp.h | 275 -- thirdparty/librdkafka-0.11.1/src/rdkafka_conf.c | 2151 --------- thirdparty/librdkafka-0.11.1/src/rdkafka_conf.h | 338 -- .../librdkafka-0.11.1/src/rdkafka_event.c | 232 - .../librdkafka-0.11.1/src/rdkafka_event.h | 81 - .../librdkafka-0.11.1/src/rdkafka_feature.c | 444 -- .../librdkafka-0.11.1/src/rdkafka_feature.h | 79 - thirdparty/librdkafka-0.11.1/src/rdkafka_int.h | 435 -- .../librdkafka-0.11.1/src/rdkafka_interceptor.c | 624 --- .../librdkafka-0.11.1/src/rdkafka_interceptor.h | 71 - thirdparty/librdkafka-0.11.1/src/rdkafka_lz4.c | 429 -- thirdparty/librdkafka-0.11.1/src/rdkafka_lz4.h | 40 - .../librdkafka-0.11.1/src/rdkafka_metadata.c | 1017 ----- .../librdkafka-0.11.1/src/rdkafka_metadata.h | 157 - .../src/rdkafka_metadata_cache.c | 732 --- thirdparty/librdkafka-0.11.1/src/rdkafka_msg.c | 800 ---- thirdparty/librdkafka-0.11.1/src/rdkafka_msg.h | 290 -- .../librdkafka-0.11.1/src/rdkafka_msgset.h | 47 - .../src/rdkafka_msgset_reader.c | 1090 ----- .../src/rdkafka_msgset_writer.c | 1161 ----- .../librdkafka-0.11.1/src/rdkafka_offset.c | 1139 ----- .../librdkafka-0.11.1/src/rdkafka_offset.h | 72 - thirdparty/librdkafka-0.11.1/src/rdkafka_op.c | 662 --- thirdparty/librdkafka-0.11.1/src/rdkafka_op.h | 400 -- .../librdkafka-0.11.1/src/rdkafka_partition.c | 3272 -------------- .../librdkafka-0.11.1/src/rdkafka_partition.h | 636 --- .../librdkafka-0.11.1/src/rdkafka_pattern.c | 224 - .../librdkafka-0.11.1/src/rdkafka_pattern.h | 65 - .../librdkafka-0.11.1/src/rdkafka_plugin.c | 209 - .../librdkafka-0.11.1/src/rdkafka_plugin.h | 37 - .../librdkafka-0.11.1/src/rdkafka_proto.h | 498 --- .../librdkafka-0.11.1/src/rdkafka_queue.c | 860 ---- .../librdkafka-0.11.1/src/rdkafka_queue.h | 731 --- .../src/rdkafka_range_assignor.c | 125 - .../librdkafka-0.11.1/src/rdkafka_request.c | 1848 -------- .../librdkafka-0.11.1/src/rdkafka_request.h | 196 - .../src/rdkafka_roundrobin_assignor.c | 114 - thirdparty/librdkafka-0.11.1/src/rdkafka_sasl.c | 343 -- thirdparty/librdkafka-0.11.1/src/rdkafka_sasl.h | 46 - .../librdkafka-0.11.1/src/rdkafka_sasl_cyrus.c | 623 --- .../librdkafka-0.11.1/src/rdkafka_sasl_int.h | 70 - .../librdkafka-0.11.1/src/rdkafka_sasl_plain.c | 128 - .../librdkafka-0.11.1/src/rdkafka_sasl_scram.c | 901 ---- .../librdkafka-0.11.1/src/rdkafka_sasl_win32.c | 526 --- .../src/rdkafka_subscription.c | 187 - .../src/rdkafka_subscription.h | 31 - .../librdkafka-0.11.1/src/rdkafka_timer.c | 292 -- .../librdkafka-0.11.1/src/rdkafka_timer.h | 77 - .../librdkafka-0.11.1/src/rdkafka_topic.c | 1306 ------ .../librdkafka-0.11.1/src/rdkafka_topic.h | 185 - .../librdkafka-0.11.1/src/rdkafka_transport.c | 1523 ------- .../librdkafka-0.11.1/src/rdkafka_transport.h | 72 - .../src/rdkafka_transport_int.h | 84 - thirdparty/librdkafka-0.11.1/src/rdlist.c | 313 -- thirdparty/librdkafka-0.11.1/src/rdlist.h | 246 - thirdparty/librdkafka-0.11.1/src/rdlog.c | 89 - thirdparty/librdkafka-0.11.1/src/rdlog.h | 37 - thirdparty/librdkafka-0.11.1/src/rdports.c | 60 - thirdparty/librdkafka-0.11.1/src/rdports.h | 33 - thirdparty/librdkafka-0.11.1/src/rdposix.h | 182 - thirdparty/librdkafka-0.11.1/src/rdrand.c | 50 - thirdparty/librdkafka-0.11.1/src/rdrand.h | 45 - thirdparty/librdkafka-0.11.1/src/rdregex.c | 157 - thirdparty/librdkafka-0.11.1/src/rdregex.h | 37 - thirdparty/librdkafka-0.11.1/src/rdsignal.h | 54 - thirdparty/librdkafka-0.11.1/src/rdstring.c | 162 - thirdparty/librdkafka-0.11.1/src/rdstring.h | 52 - thirdparty/librdkafka-0.11.1/src/rdsysqueue.h | 330 -- thirdparty/librdkafka-0.11.1/src/rdtime.h | 175 - thirdparty/librdkafka-0.11.1/src/rdtypes.h | 42 - thirdparty/librdkafka-0.11.1/src/rdunittest.c | 43 - thirdparty/librdkafka-0.11.1/src/rdunittest.h | 83 - thirdparty/librdkafka-0.11.1/src/rdvarint.c | 126 - thirdparty/librdkafka-0.11.1/src/rdvarint.h | 169 - thirdparty/librdkafka-0.11.1/src/rdwin32.h | 262 -- thirdparty/librdkafka-0.11.1/src/regexp.c | 1156 ----- thirdparty/librdkafka-0.11.1/src/regexp.h | 31 - thirdparty/librdkafka-0.11.1/src/snappy.c | 1834 -------- thirdparty/librdkafka-0.11.1/src/snappy.h | 34 - .../librdkafka-0.11.1/src/snappy_compat.h | 169 - thirdparty/librdkafka-0.11.1/src/tinycthread.c | 1031 ----- thirdparty/librdkafka-0.11.1/src/tinycthread.h | 520 --- thirdparty/librdkafka-0.11.1/src/win32_config.h | 40 - thirdparty/librdkafka-0.11.1/src/xxhash.c | 889 ---- thirdparty/librdkafka-0.11.1/src/xxhash.h | 293 -- thirdparty/librdkafka-0.11.1/win32/.gitignore | 109 - thirdparty/librdkafka-0.11.1/win32/README.md | 5 - .../librdkafka-0.11.1/win32/build-package.bat | 3 - thirdparty/librdkafka-0.11.1/win32/build.bat | 19 - .../librdkafka-0.11.1/win32/common.vcxproj | 76 - .../interceptor_test/interceptor_test.vcxproj | 87 - .../win32/librdkafka.autopkg.template | 55 - .../win32/librdkafka.master.testing.targets | 13 - .../librdkafka-0.11.1/win32/librdkafka.sln | 176 - .../librdkafka-0.11.1/win32/librdkafka.vcxproj | 229 - .../win32/librdkafkacpp/librdkafkacpp.vcxproj | 103 - .../librdkafka-0.11.1/win32/package-nuget.ps1 | 21 - .../librdkafka-0.11.1/win32/packages.config | 6 - .../win32/packages/repositories.config | 4 - .../librdkafka-0.11.1/win32/push-package.bat | 4 - .../rdkafka_consumer_example_cpp.vcxproj | 67 - .../rdkafka_example/rdkafka_example.vcxproj | 97 - .../rdkafka_performance.vcxproj | 97 - .../librdkafka-0.11.1/win32/tests/.gitignore | 3 - .../win32/tests/test.conf.example | 25 - .../librdkafka-0.11.1/win32/tests/tests.vcxproj | 171 - thirdparty/librdkafka-0.11.1/win32/wingetopt.c | 564 --- thirdparty/librdkafka-0.11.1/win32/wingetopt.h | 95 - thirdparty/librdkafka-0.11.1/win32/wintime.h | 29 - thirdparty/librdkafka-0.11.4/.appveyor.yml | 88 + thirdparty/librdkafka-0.11.4/.dir-locals.el | 3 + thirdparty/librdkafka-0.11.4/.doozer.json | 110 + .../librdkafka-0.11.4/.github/ISSUE_TEMPLATE | 32 + thirdparty/librdkafka-0.11.4/.gitignore | 28 + thirdparty/librdkafka-0.11.4/.travis.yml | 42 + thirdparty/librdkafka-0.11.4/CMakeLists.txt | 182 + thirdparty/librdkafka-0.11.4/CODE_OF_CONDUCT.md | 46 + thirdparty/librdkafka-0.11.4/CONFIGURATION.md | 138 + thirdparty/librdkafka-0.11.4/CONTRIBUTING.md | 271 ++ thirdparty/librdkafka-0.11.4/Doxyfile | 2385 ++++++++++ thirdparty/librdkafka-0.11.4/INTRODUCTION.md | 735 +++ thirdparty/librdkafka-0.11.4/LICENSE | 25 + thirdparty/librdkafka-0.11.4/LICENSE.crc32c | 28 + thirdparty/librdkafka-0.11.4/LICENSE.lz4 | 26 + thirdparty/librdkafka-0.11.4/LICENSE.murmur2 | 25 + thirdparty/librdkafka-0.11.4/LICENSE.pycrc | 23 + thirdparty/librdkafka-0.11.4/LICENSE.queue | 31 + thirdparty/librdkafka-0.11.4/LICENSE.regexp | 5 + thirdparty/librdkafka-0.11.4/LICENSE.snappy | 36 + .../librdkafka-0.11.4/LICENSE.tinycthread | 26 + thirdparty/librdkafka-0.11.4/LICENSE.wingetopt | 49 + thirdparty/librdkafka-0.11.4/LICENSES.txt | 313 ++ thirdparty/librdkafka-0.11.4/Makefile | 68 + thirdparty/librdkafka-0.11.4/README.md | 168 + thirdparty/librdkafka-0.11.4/README.win32 | 28 + thirdparty/librdkafka-0.11.4/configure | 214 + .../librdkafka-0.11.4/configure.librdkafka | 215 + thirdparty/librdkafka-0.11.4/dev-conf.sh | 45 + .../librdkafka-0.11.4/examples/.gitignore | 8 + .../librdkafka-0.11.4/examples/CMakeLists.txt | 30 + thirdparty/librdkafka-0.11.4/examples/Makefile | 96 + .../librdkafka-0.11.4/examples/globals.json | 11 + .../examples/kafkatest_verifiable_client.cpp | 960 ++++ .../examples/rdkafka_consume_batch.cpp | 260 ++ .../examples/rdkafka_consumer_example.c | 624 +++ .../examples/rdkafka_consumer_example.cpp | 485 ++ .../examples/rdkafka_example.c | 885 ++++ .../examples/rdkafka_example.cpp | 645 +++ .../examples/rdkafka_performance.c | 1651 +++++++ .../examples/rdkafka_simple_producer.c | 260 ++ .../examples/rdkafka_zookeeper_example.c | 728 +++ thirdparty/librdkafka-0.11.4/lds-gen.py | 38 + thirdparty/librdkafka-0.11.4/mainpage.doxy | 35 + .../librdkafka-0.11.4/mklove/Makefile.base | 215 + .../mklove/modules/configure.atomics | 144 + .../mklove/modules/configure.base | 1771 ++++++++ .../mklove/modules/configure.builtin | 62 + .../mklove/modules/configure.cc | 178 + .../mklove/modules/configure.cxx | 8 + .../mklove/modules/configure.fileversion | 65 + .../mklove/modules/configure.gitversion | 19 + .../mklove/modules/configure.good_cflags | 18 + .../mklove/modules/configure.host | 110 + .../mklove/modules/configure.lib | 49 + .../mklove/modules/configure.parseversion | 95 + .../mklove/modules/configure.pic | 16 + .../mklove/modules/configure.socket | 20 + .../librdkafka-0.11.4/packaging/RELEASE.md | 137 + .../packaging/archlinux/PKGBUILD | 5 + .../packaging/cmake/Config.cmake.in | 20 + .../librdkafka-0.11.4/packaging/cmake/README.md | 38 + .../packaging/cmake/config.h.in | 40 + .../cmake/try_compile/atomic_32_test.c | 8 + .../cmake/try_compile/atomic_64_test.c | 8 + .../packaging/cmake/try_compile/dlopen_test.c | 11 + .../packaging/cmake/try_compile/libsasl2_test.c | 7 + .../cmake/try_compile/rdkafka_setup.cmake | 76 + .../packaging/cmake/try_compile/regex_test.c | 10 + .../packaging/cmake/try_compile/strndup_test.c | 5 + .../packaging/cmake/try_compile/sync_32_test.c | 8 + .../packaging/cmake/try_compile/sync_64_test.c | 8 + .../packaging/debian/.gitignore | 6 + .../packaging/debian/changelog | 66 + .../librdkafka-0.11.4/packaging/debian/compat | 1 + .../librdkafka-0.11.4/packaging/debian/control | 49 + .../packaging/debian/copyright | 84 + .../librdkafka-0.11.4/packaging/debian/docs | 3 + .../librdkafka-0.11.4/packaging/debian/gbp.conf | 9 + .../packaging/debian/librdkafka-dev.dirs | 2 + .../packaging/debian/librdkafka-dev.examples | 2 + .../packaging/debian/librdkafka-dev.install | 6 + .../packaging/debian/librdkafka-dev.substvars | 1 + .../packaging/debian/librdkafka.dsc | 16 + .../packaging/debian/librdkafka1-dbg.substvars | 1 + .../packaging/debian/librdkafka1.dirs | 1 + .../packaging/debian/librdkafka1.install | 2 + .../debian/librdkafka1.postinst.debhelper | 5 + .../debian/librdkafka1.postrm.debhelper | 5 + .../packaging/debian/librdkafka1.symbols | 64 + .../librdkafka-0.11.4/packaging/debian/rules | 19 + .../packaging/debian/source/format | 1 + .../librdkafka-0.11.4/packaging/debian/watch | 2 + .../librdkafka-0.11.4/packaging/get_version.py | 21 + .../packaging/homebrew/README.md | 15 + .../packaging/homebrew/brew-update-pr.sh | 31 + .../packaging/nuget/.gitignore | 5 + .../librdkafka-0.11.4/packaging/nuget/README.md | 50 + .../packaging/nuget/artifact.py | 173 + .../msvcr120.zip | Bin 0 -> 520101 bytes .../msvcr120.zip | Bin 0 -> 461473 bytes .../librdkafka-0.11.4/packaging/nuget/nuget.sh | 21 + .../packaging/nuget/packaging.py | 421 ++ .../packaging/nuget/release.py | 83 + .../packaging/nuget/requirements.txt | 2 + .../nuget/templates/librdkafka.redist.nuspec | 21 + .../nuget/templates/librdkafka.redist.props | 18 + .../nuget/templates/librdkafka.redist.targets | 19 + .../packaging/nuget/zfile/__init__.py | 0 .../packaging/nuget/zfile/zfile.py | 100 + .../librdkafka-0.11.4/packaging/rpm/.gitignore | 3 + .../librdkafka-0.11.4/packaging/rpm/Makefile | 81 + .../packaging/rpm/el7-x86_64.cfg | 40 + .../packaging/rpm/librdkafka.spec | 104 + .../packaging/tools/build-debian.sh | 53 + .../librdkafka-0.11.4/src-cpp/CMakeLists.txt | 35 + .../librdkafka-0.11.4/src-cpp/ConfImpl.cpp | 89 + .../librdkafka-0.11.4/src-cpp/ConsumerImpl.cpp | 233 + .../librdkafka-0.11.4/src-cpp/HandleImpl.cpp | 365 ++ .../src-cpp/KafkaConsumerImpl.cpp | 257 ++ thirdparty/librdkafka-0.11.4/src-cpp/Makefile | 49 + .../librdkafka-0.11.4/src-cpp/MessageImpl.cpp | 38 + .../librdkafka-0.11.4/src-cpp/MetadataImpl.cpp | 151 + .../librdkafka-0.11.4/src-cpp/ProducerImpl.cpp | 167 + .../librdkafka-0.11.4/src-cpp/QueueImpl.cpp | 71 + thirdparty/librdkafka-0.11.4/src-cpp/README.md | 16 + .../librdkafka-0.11.4/src-cpp/RdKafka.cpp | 52 + .../librdkafka-0.11.4/src-cpp/TopicImpl.cpp | 128 + .../src-cpp/TopicPartitionImpl.cpp | 55 + .../librdkafka-0.11.4/src-cpp/rdkafkacpp.h | 2284 ++++++++++ .../librdkafka-0.11.4/src-cpp/rdkafkacpp_int.h | 910 ++++ thirdparty/librdkafka-0.11.4/src/CMakeLists.txt | 184 + thirdparty/librdkafka-0.11.4/src/Makefile | 82 + thirdparty/librdkafka-0.11.4/src/crc32c.c | 438 ++ thirdparty/librdkafka-0.11.4/src/crc32c.h | 38 + .../src/librdkafka_cgrp_synch.png | Bin 0 -> 93796 bytes thirdparty/librdkafka-0.11.4/src/lz4.c | 1462 ++++++ thirdparty/librdkafka-0.11.4/src/lz4.h | 463 ++ thirdparty/librdkafka-0.11.4/src/lz4frame.c | 1440 ++++++ thirdparty/librdkafka-0.11.4/src/lz4frame.h | 367 ++ .../librdkafka-0.11.4/src/lz4frame_static.h | 98 + thirdparty/librdkafka-0.11.4/src/lz4hc.c | 786 ++++ thirdparty/librdkafka-0.11.4/src/lz4hc.h | 269 ++ thirdparty/librdkafka-0.11.4/src/lz4opt.h | 360 ++ thirdparty/librdkafka-0.11.4/src/queue.h | 850 ++++ thirdparty/librdkafka-0.11.4/src/rd.h | 457 ++ thirdparty/librdkafka-0.11.4/src/rdaddr.c | 220 + thirdparty/librdkafka-0.11.4/src/rdaddr.h | 187 + thirdparty/librdkafka-0.11.4/src/rdatomic.h | 191 + thirdparty/librdkafka-0.11.4/src/rdavg.h | 97 + thirdparty/librdkafka-0.11.4/src/rdavl.c | 214 + thirdparty/librdkafka-0.11.4/src/rdavl.h | 256 ++ thirdparty/librdkafka-0.11.4/src/rdbuf.c | 1550 +++++++ thirdparty/librdkafka-0.11.4/src/rdbuf.h | 325 ++ thirdparty/librdkafka-0.11.4/src/rdcrc32.c | 113 + thirdparty/librdkafka-0.11.4/src/rdcrc32.h | 146 + thirdparty/librdkafka-0.11.4/src/rddl.c | 179 + thirdparty/librdkafka-0.11.4/src/rddl.h | 41 + thirdparty/librdkafka-0.11.4/src/rdendian.h | 169 + thirdparty/librdkafka-0.11.4/src/rdgz.c | 124 + thirdparty/librdkafka-0.11.4/src/rdgz.h | 45 + thirdparty/librdkafka-0.11.4/src/rdinterval.h | 117 + thirdparty/librdkafka-0.11.4/src/rdkafka.c | 3518 +++++++++++++++ thirdparty/librdkafka-0.11.4/src/rdkafka.h | 4211 ++++++++++++++++++ .../librdkafka-0.11.4/src/rdkafka_assignor.c | 551 +++ .../librdkafka-0.11.4/src/rdkafka_assignor.h | 159 + .../librdkafka-0.11.4/src/rdkafka_broker.c | 4038 +++++++++++++++++ .../librdkafka-0.11.4/src/rdkafka_broker.h | 361 ++ thirdparty/librdkafka-0.11.4/src/rdkafka_buf.c | 451 ++ thirdparty/librdkafka-0.11.4/src/rdkafka_buf.h | 946 ++++ thirdparty/librdkafka-0.11.4/src/rdkafka_cgrp.c | 3262 ++++++++++++++ thirdparty/librdkafka-0.11.4/src/rdkafka_cgrp.h | 278 ++ thirdparty/librdkafka-0.11.4/src/rdkafka_conf.c | 2248 ++++++++++ thirdparty/librdkafka-0.11.4/src/rdkafka_conf.h | 350 ++ .../librdkafka-0.11.4/src/rdkafka_event.c | 232 + .../librdkafka-0.11.4/src/rdkafka_event.h | 81 + .../librdkafka-0.11.4/src/rdkafka_feature.c | 444 ++ .../librdkafka-0.11.4/src/rdkafka_feature.h | 82 + .../librdkafka-0.11.4/src/rdkafka_header.c | 222 + .../librdkafka-0.11.4/src/rdkafka_header.h | 76 + thirdparty/librdkafka-0.11.4/src/rdkafka_int.h | 446 ++ .../librdkafka-0.11.4/src/rdkafka_interceptor.c | 675 +++ .../librdkafka-0.11.4/src/rdkafka_interceptor.h | 80 + thirdparty/librdkafka-0.11.4/src/rdkafka_lz4.c | 436 ++ thirdparty/librdkafka-0.11.4/src/rdkafka_lz4.h | 43 + .../librdkafka-0.11.4/src/rdkafka_metadata.c | 1031 +++++ .../librdkafka-0.11.4/src/rdkafka_metadata.h | 160 + .../src/rdkafka_metadata_cache.c | 732 +++ thirdparty/librdkafka-0.11.4/src/rdkafka_msg.c | 1277 ++++++ thirdparty/librdkafka-0.11.4/src/rdkafka_msg.h | 381 ++ .../librdkafka-0.11.4/src/rdkafka_msgset.h | 50 + .../src/rdkafka_msgset_reader.c | 1137 +++++ .../src/rdkafka_msgset_writer.c | 1226 +++++ .../librdkafka-0.11.4/src/rdkafka_offset.c | 1145 +++++ .../librdkafka-0.11.4/src/rdkafka_offset.h | 74 + thirdparty/librdkafka-0.11.4/src/rdkafka_op.c | 660 +++ thirdparty/librdkafka-0.11.4/src/rdkafka_op.h | 403 ++ .../librdkafka-0.11.4/src/rdkafka_partition.c | 3363 ++++++++++++++ .../librdkafka-0.11.4/src/rdkafka_partition.h | 641 +++ .../librdkafka-0.11.4/src/rdkafka_pattern.c | 224 + .../librdkafka-0.11.4/src/rdkafka_pattern.h | 68 + .../librdkafka-0.11.4/src/rdkafka_plugin.c | 209 + .../librdkafka-0.11.4/src/rdkafka_plugin.h | 37 + .../librdkafka-0.11.4/src/rdkafka_proto.h | 502 +++ .../librdkafka-0.11.4/src/rdkafka_queue.c | 866 ++++ .../librdkafka-0.11.4/src/rdkafka_queue.h | 769 ++++ .../src/rdkafka_range_assignor.c | 125 + .../librdkafka-0.11.4/src/rdkafka_request.c | 1997 +++++++++ .../librdkafka-0.11.4/src/rdkafka_request.h | 198 + .../src/rdkafka_roundrobin_assignor.c | 114 + thirdparty/librdkafka-0.11.4/src/rdkafka_sasl.c | 343 ++ thirdparty/librdkafka-0.11.4/src/rdkafka_sasl.h | 49 + .../librdkafka-0.11.4/src/rdkafka_sasl_cyrus.c | 623 +++ .../librdkafka-0.11.4/src/rdkafka_sasl_int.h | 72 + .../librdkafka-0.11.4/src/rdkafka_sasl_plain.c | 128 + .../librdkafka-0.11.4/src/rdkafka_sasl_scram.c | 901 ++++ .../librdkafka-0.11.4/src/rdkafka_sasl_win32.c | 526 +++ .../src/rdkafka_subscription.c | 186 + .../librdkafka-0.11.4/src/rdkafka_timer.c | 292 ++ .../librdkafka-0.11.4/src/rdkafka_timer.h | 80 + .../librdkafka-0.11.4/src/rdkafka_topic.c | 1310 ++++++ .../librdkafka-0.11.4/src/rdkafka_topic.h | 188 + .../librdkafka-0.11.4/src/rdkafka_transport.c | 1607 +++++++ .../librdkafka-0.11.4/src/rdkafka_transport.h | 79 + .../src/rdkafka_transport_int.h | 87 + thirdparty/librdkafka-0.11.4/src/rdlist.c | 333 ++ thirdparty/librdkafka-0.11.4/src/rdlist.h | 269 ++ thirdparty/librdkafka-0.11.4/src/rdlog.c | 89 + thirdparty/librdkafka-0.11.4/src/rdlog.h | 40 + thirdparty/librdkafka-0.11.4/src/rdmurmur2.c | 159 + thirdparty/librdkafka-0.11.4/src/rdmurmur2.h | 7 + thirdparty/librdkafka-0.11.4/src/rdports.c | 60 + thirdparty/librdkafka-0.11.4/src/rdports.h | 36 + thirdparty/librdkafka-0.11.4/src/rdposix.h | 184 + thirdparty/librdkafka-0.11.4/src/rdrand.c | 50 + thirdparty/librdkafka-0.11.4/src/rdrand.h | 48 + thirdparty/librdkafka-0.11.4/src/rdregex.c | 157 + thirdparty/librdkafka-0.11.4/src/rdregex.h | 40 + thirdparty/librdkafka-0.11.4/src/rdsignal.h | 57 + thirdparty/librdkafka-0.11.4/src/rdstring.c | 204 + thirdparty/librdkafka-0.11.4/src/rdstring.h | 59 + thirdparty/librdkafka-0.11.4/src/rdsysqueue.h | 348 ++ thirdparty/librdkafka-0.11.4/src/rdtime.h | 184 + thirdparty/librdkafka-0.11.4/src/rdtypes.h | 45 + thirdparty/librdkafka-0.11.4/src/rdunittest.c | 63 + thirdparty/librdkafka-0.11.4/src/rdunittest.h | 83 + thirdparty/librdkafka-0.11.4/src/rdvarint.c | 126 + thirdparty/librdkafka-0.11.4/src/rdvarint.h | 169 + thirdparty/librdkafka-0.11.4/src/rdwin32.h | 265 ++ thirdparty/librdkafka-0.11.4/src/regexp.c | 1156 +++++ thirdparty/librdkafka-0.11.4/src/regexp.h | 31 + thirdparty/librdkafka-0.11.4/src/snappy.c | 1838 ++++++++ thirdparty/librdkafka-0.11.4/src/snappy.h | 34 + .../librdkafka-0.11.4/src/snappy_compat.h | 169 + thirdparty/librdkafka-0.11.4/src/tinycthread.c | 1039 +++++ thirdparty/librdkafka-0.11.4/src/tinycthread.h | 528 +++ thirdparty/librdkafka-0.11.4/src/win32_config.h | 45 + thirdparty/librdkafka-0.11.4/src/xxhash.c | 889 ++++ thirdparty/librdkafka-0.11.4/src/xxhash.h | 293 ++ 532 files changed, 89176 insertions(+), 87272 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/7528d23e/CMakeLists.txt ---------------------------------------------------------------------- diff --git a/CMakeLists.txt b/CMakeLists.txt index 7699d1f..287e44d 100644 --- a/CMakeLists.txt +++ b/CMakeLists.txt @@ -250,7 +250,7 @@ endif() ## Create LibRdKafka Extension option(ENABLE_LIBRDKAFKA "Enables the librdkafka extension." OFF) if (ENABLE_ALL OR ENABLE_LIBRDKAFKA) - createExtension(RDKAFKA-EXTENSIONS "RDKAFKA EXTENSIONS" "This Enables librdkafka functionality including PublishKafka" "extensions/librdkafka" "${TEST_DIR}/kafka-tests" "TRUE" "thirdparty/librdkafka-0.11.1") + createExtension(RDKAFKA-EXTENSIONS "RDKAFKA EXTENSIONS" "This Enables librdkafka functionality including PublishKafka" "extensions/librdkafka" "${TEST_DIR}/kafka-tests" "TRUE" "thirdparty/librdkafka-0.11.4") endif() ## Scripting extensions http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/7528d23e/libminifi/test/kafka-tests/CMakeLists.txt ---------------------------------------------------------------------- diff --git a/libminifi/test/kafka-tests/CMakeLists.txt b/libminifi/test/kafka-tests/CMakeLists.txt index 1e465b1..5172ca2 100644 --- a/libminifi/test/kafka-tests/CMakeLists.txt +++ b/libminifi/test/kafka-tests/CMakeLists.txt @@ -24,8 +24,8 @@ FOREACH(testfile ${KAFKA_INTEGRATION_TESTS}) get_filename_component(testfilename "${testfile}" NAME_WE) add_executable("${testfilename}" "${testfile}") target_include_directories(${testfilename} BEFORE PRIVATE "${CMAKE_SOURCE_DIR}/extensions/librdkafka") - target_include_directories(${testfilename} BEFORE PRIVATE "${CMAKE_SOURCE_DIR}/thirdparty/librdkafka-0.11.1/src") - target_include_directories(${testfilename} BEFORE PRIVATE "${CMAKE_SOURCE_DIR}/thirdparty/librdkafka-0.11.1/src-cpp") + target_include_directories(${testfilename} BEFORE PRIVATE "${CMAKE_SOURCE_DIR}/thirdparty/librdkafka-0.11.4/src") + target_include_directories(${testfilename} BEFORE PRIVATE "${CMAKE_SOURCE_DIR}/thirdparty/librdkafka-0.11.4/src-cpp") createTests("${testfilename}") target_link_libraries(${testfilename} ${CATCH_MAIN_LIB}) if (APPLE) http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/7528d23e/thirdparty/librdkafka-0.11.1/.appveyor.yml ---------------------------------------------------------------------- diff --git a/thirdparty/librdkafka-0.11.1/.appveyor.yml b/thirdparty/librdkafka-0.11.1/.appveyor.yml deleted file mode 100644 index aac3a68..0000000 --- a/thirdparty/librdkafka-0.11.1/.appveyor.yml +++ /dev/null @@ -1,88 +0,0 @@ -version: 0.11.0-R-post{build} -pull_requests: - do_not_increment_build_number: true -image: Visual Studio 2013 -configuration: Release -environment: - matrix: - - platform: x64 - - platform: win32 -install: -- ps: "$OpenSSLVersion = \"1_0_2L\"\n$OpenSSLExe = \"OpenSSL-$OpenSSLVersion.exe\"\n\nRemove-Item C:\\OpenSSL-Win32 -recurse\nRemove-Item C:\\OpenSSL-Win64 -recurse\n\nWrite-Host \"Installing OpenSSL v1.0 32-bit ...\" -ForegroundColor Cyan\nWrite-Host \"Downloading...\"\n$exePath = \"$($env:USERPROFILE)\\Win32OpenSSL-1_0_2L.exe\"\n(New-Object Net.WebClient).DownloadFile('https://slproweb.com/download/Win32OpenSSL-1_0_2L.exe', $exePath)\nWrite-Host \"Installing...\"\ncmd /c start /wait $exePath /silent /verysilent /sp- /suppressmsgboxes /DIR=C:\\OpenSSL-Win32\nWrite-Host \"Installed\" -ForegroundColor Green\n\nWrite-Host \"Installing OpenSSL v1.0 64-bit ...\" -ForegroundColor Cyan\nWrite-Host \"Downloading...\"\n$exePath = \"$($env:USERPROFILE)\\Win64OpenSSL-1_0_2L.exe\"\n(New-Object Net.WebClient).DownloadFile('https://slproweb.com/download/Win64OpenSSL-1_0_2L.exe', $exePath)\nWrite-Host \"Installing...\"\ncmd /c start /wait $exePath /silent /verysilent /sp- /suppressmsgboxes /DIR=C :\\OpenSSL-Win64\nWrite-Host \"Installed\" -ForegroundColor Green\n\nif (!(Test-Path(\"C:\\OpenSSL-Win32\"))) {\n echo \"Downloading https://slproweb.com/download/Win32$OpenSSLExe\"\n Start-FileDownload 'https://slproweb.com/download/Win32$OpenSSLExe'\n Start-Process \"Win32$OpenSSLExe\" -ArgumentList \"/silent /verysilent /sp- /suppressmsgboxes\" -Wait\n} else {\n echo \"OpenSSL-Win32 already exists: not downloading\"\n}\n\nif (!(Test-Path(\"C:\\OpenSSL-Win64\"))) {\n echo \"Downloading https://slproweb.com/download/Win64$OpenSSLExe\"\n Start-FileDownload 'https://slproweb.com/download/Win64$OpenSSLExe' \n Start-Process \"Win64$OpenSSLExe\" -ArgumentList \"/silent /verysilent /sp- /suppressmsgboxes\" -Wait\n} else {\n echo \"OpenSSL-Win64 already exists: not downloading\"\n}\n\n\n\n# Download the CoApp tools.\n$msiPath = \"$($env:USERPROFILE)\\CoApp.Tools.Powershell.msi\"\n(New-Object Net.WebClient).DownloadFile('http://coapp.org/files/CoApp.Tools.Powershell.msi', $msiPat h)\n\n# Install the CoApp tools from the downloaded .msi.\nStart-Process -FilePath msiexec -ArgumentList /i, $msiPath, /quiet -Wait\n\n# Make the tools available for later PS scripts to use.\n$env:PSModulePath = $env:PSModulePath + ';C:\\Program Files (x86)\\Outercurve Foundation\\Modules'\nImport-Module CoApp\n\n# Install NuGet\n#Install-PackageProvider NuGet -MinimumVersion '2.8.5.201' -Force\n#Import-PackageProvider NuGet -MinimumVersion '2.8.5.201' -Force\n\n# Install CoApp for creating nuget packages\n#$msiPath = \"$($env:USERPROFILE)\\CoApp.Tools.Powershell.msi\"\n#(New-Object #Net.WebClient).DownloadFile('http://downloads.coapp.org/files/CoApp.Tools.Powershell.msi', $msiPath)\n#cmd /c start /wait msiexec /i \"$msiPath\" /quiet\n\n# Install CoApp module\n#Install-Module CoApp -Force" -cache: -- c:\OpenSSL-Win32 -- c:\OpenSSL-Win64 -nuget: - account_feed: true - project_feed: true - disable_publish_on_pr: true -before_build: -- cmd: nuget restore win32/librdkafka.sln -build: - project: win32/librdkafka.sln - publish_nuget: true - publish_nuget_symbols: true - include_nuget_references: true - parallel: true - verbosity: normal -test_script: -- cmd: if exist DISABLED\win32\outdir\v140 ( win32\outdir\v140\%PLATFORM%\%CONFIGURATION%\tests.exe -l -p1 ) else ( win32\outdir\v120\%PLATFORM%\%CONFIGURATION%\tests.exe -l -p1 ) -artifacts: -- path: test_report*.json - name: Test report -- path: '*.nupkg' - name: Packages -- path: '**\*.dll' - name: Libraries -- path: '**\*.lib' - name: Libraries -- path: '**\*.pdb' - name: Libraries -- path: '**\*.exe' - name: Executables -before_deploy: -- ps: >- - # FIXME: Add to Deployment condition above: - - # APPVEYOR_REPO_TAG = true - - - - # This is the CoApp .autopkg file to create. - - $autopkgFile = "win32/librdkafka.autopkg" - - - # Get the ".autopkg.template" file, replace "@version" with the Appveyor version number, then save to the ".autopkg" file. - - cat ($autopkgFile + ".template") | % { $_ -replace "@version", $env:appveyor_build_version } > $autopkgFile - - - # Use the CoApp tools to create NuGet native packages from the .autopkg. - - Write-NuGetPackage $autopkgFile - - - # Push all newly created .nupkg files as Appveyor artifacts for later deployment. - - Get-ChildItem .\*.nupkg | % { Push-AppveyorArtifact $_.FullName -FileName $_.Name } -deploy: -- provider: S3 - access_key_id: - secure: BDJ8FdNEzVKO7MTZX50dWIvrBEPOl9oHSRQ9S/s3uu0= - secret_access_key: - secure: GBmNSeDpUa7hqqTJBT+PLMgsZCxQMBau+6Vnitzqw15UlpuaZRzid1s5egIacZO6 - region: us-west-1 - bucket: librdkafka-ci-packages - folder: librdkafka/p-librdkafka__bld-appveyor__plat-windows__arch-$(platform)__bldtype-$(configuration)__tag-$(APPVEYOR_REPO_TAG_NAME)__sha-$(APPVEYOR_REPO_COMMIT)__bid-$(APPVEYOR_BUILD_ID) - artifact: /.*\.(nupkg)/ - max_error_retry: 3 - on: - APPVEYOR_REPO_TAG: true -notifications: -- provider: Email - to: - - [email protected] - on_build_success: false - on_build_failure: true - on_build_status_changed: true http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/7528d23e/thirdparty/librdkafka-0.11.1/.dir-locals.el ---------------------------------------------------------------------- diff --git a/thirdparty/librdkafka-0.11.1/.dir-locals.el b/thirdparty/librdkafka-0.11.1/.dir-locals.el deleted file mode 100644 index 22ca922..0000000 --- a/thirdparty/librdkafka-0.11.1/.dir-locals.el +++ /dev/null @@ -1,3 +0,0 @@ -( (c-mode . ((c-file-style . "linux"))) ) -((nil . ((compile-command . "LC_ALL=C make -C $(git rev-parse --show-toplevels) -k")))) - http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/7528d23e/thirdparty/librdkafka-0.11.1/.doozer.json ---------------------------------------------------------------------- diff --git a/thirdparty/librdkafka-0.11.1/.doozer.json b/thirdparty/librdkafka-0.11.1/.doozer.json deleted file mode 100644 index d12f1a4..0000000 --- a/thirdparty/librdkafka-0.11.1/.doozer.json +++ /dev/null @@ -1,88 +0,0 @@ -{ - "targets": { - "xenial-amd64": { - - "buildenv": "xenial-amd64", - "builddeps": [ - "build-essential", - "python", - "zlib1g-dev", - "libssl-dev", - "libsasl2-dev" - ], - "buildcmd": [ - "./configure", - "make -j ${PARALLEL}", - "make -C tests build" - ], - "testcmd": [ - "make -C tests run_local" - ], - }, - - "xenial-i386": { - "_comment": "including liblz4-dev here to verify that WITH_LZ4_EXT works", - "buildenv": "xenial-i386", - "builddeps": [ - "build-essential", - "python", - "zlib1g-dev", - "libssl-dev", - "libsasl2-dev", - "liblz4-dev" - ], - "buildcmd": [ - "./configure", - "make -j ${PARALLEL}", - "make -C tests build" - ], - "testcmd": [ - "make -C tests run_local" - ], - }, - - "xenial-armhf": { - - "buildenv": "xenial-armhf", - "builddeps": [ - "build-essential", - "python", - "zlib1g-dev", - "libssl-dev", - "libsasl2-dev" - ], - "buildcmd": [ - "./configure", - "make -j ${PARALLEL}", - "make -j ${PARALLEL} -C tests build", - ], - "testcmd": [ - "cd tests", - "./run-test.sh -p1 -l ./merged", - "cd .." - ], - }, - - "cmake-xenial-amd64": { - - "buildenv": "xenial-amd64", - "builddeps": [ - "build-essential", - "python", - "zlib1g-dev", - "libssl-dev", - "libsasl2-dev", - "cmake" - ], - "buildcmd": [ - "cmake -H. -B_builds -DCMAKE_VERBOSE_MAKEFILE=ON -DCMAKE_BUILD_TYPE=Debug", - "cmake --build _builds", - ], - "testcmd": [ - "cd _builds", - "ctest -VV -R RdKafkaTestBrokerLess" - ], - } - }, - "artifacts": ["config.log", "Makefile.config", "config.h"] -} http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/7528d23e/thirdparty/librdkafka-0.11.1/.github/ISSUE_TEMPLATE ---------------------------------------------------------------------- diff --git a/thirdparty/librdkafka-0.11.1/.github/ISSUE_TEMPLATE b/thirdparty/librdkafka-0.11.1/.github/ISSUE_TEMPLATE deleted file mode 100644 index e36b5bc..0000000 --- a/thirdparty/librdkafka-0.11.1/.github/ISSUE_TEMPLATE +++ /dev/null @@ -1,26 +0,0 @@ -Description -=========== - - - - -How to reproduce -================ - - - - -Checklist -========= -Please provide the following information: - - - [ ] librdkafka version (release number or git tag): - - [ ] Apache Kafka version: - - [ ] librdkafka client configuration: - - [ ] Operating system: - - [ ] Using the legacy Consumer - - [ ] Using the high-level KafkaConsumer - - [ ] Provide logs (with `debug=..` as necessary) from librdkafka - - [ ] Provide broker log excerpts - - [ ] Critical issue - http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/7528d23e/thirdparty/librdkafka-0.11.1/.gitignore ---------------------------------------------------------------------- diff --git a/thirdparty/librdkafka-0.11.1/.gitignore b/thirdparty/librdkafka-0.11.1/.gitignore deleted file mode 100644 index 4a46417..0000000 --- a/thirdparty/librdkafka-0.11.1/.gitignore +++ /dev/null @@ -1,29 +0,0 @@ -config.h -config.log* -config.cache -Makefile.config -rdkafka*.pc -*~ -\#* -*.o -*.so -*.so.? -*.dylib -*.a -*.d -librdkafka*.lds -core -vgcore.* -*dSYM/ -*.offset -SOURCES -gmon.out -*.zip -*.gz -*.bz2 -*.deb -*.rpm -staging-docs -tmp -stats*.json -test_report*.json http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/7528d23e/thirdparty/librdkafka-0.11.1/.travis.yml ---------------------------------------------------------------------- diff --git a/thirdparty/librdkafka-0.11.1/.travis.yml b/thirdparty/librdkafka-0.11.1/.travis.yml deleted file mode 100644 index 59d7af7..0000000 --- a/thirdparty/librdkafka-0.11.1/.travis.yml +++ /dev/null @@ -1,41 +0,0 @@ -language: c -cache: ccache -env: -- ARCH=x64 -compiler: -- gcc -- clang -os: -- linux -- osx -dist: trusty -sudo: false -before_install: - - if [[ "${TRAVIS_OS_NAME}_$CC" == "linux_gcc" ]]; then sudo make -C packaging/rpm MOCK_CONFIG=el7-x86_64 prepare_ubuntu ; fi -before_script: - - ccache -s || echo "CCache is not available." -script: -- rm -rf artifacts dest -- mkdir dest artifacts -- if [[ "$TRAVIS_OS_NAME" == "osx" ]]; then CPPFLAGS="-I/usr/local/opt/openssl/include - -L/usr/local/opt/openssl/lib" ./configure --enable-static --disable-lz4 --prefix="$PWD/dest" ; else ./configure --enable-static --disable-lz4 --prefix="$PWD/dest" ; fi -- make -j2 all examples check && make -C tests run_local -- make install -- (cd dest && tar cvzf ../artifacts/librdkafka.tar.gz .) -- if [[ "${TRAVIS_OS_NAME}_$CC" == "linux_gcc" ]]; then sudo make -C packaging/rpm MOCK_CONFIG=el7-x86_64 all copy-artifacts ; fi -deploy: - provider: s3 - access_key_id: - secure: "i7IAO5z6xYeVaOnFiJOz0wluH7CfGf39TiABQG/yQIIp53fRu+X94FBUS7xq2PziKV08ak8pNWWjenwRB/viPTGqFQDS/ypymhSGGQVTmhgG372ypODhqbnvzskMNe1wp+UFIl8LFVEaHMVPEwWVuYpXhWNMHGrr4uSQhF+5r0Y=" - secret_access_key: - secure: q7rWZkwQqyIFu3i32y/rJsKF1AJpwIqQe3AhBFEqjCz80mdEYysvcHBfl956EAAr4qbR3umIKbkhRwbBVyDGlMaraZiR7YFgAO+v0DRFeMiF5XFE3KHNIpCQHSKnzOiL65TpJHZIoB+6w0lAbBVzj87MBN0axAeArHKiO1y8Eec= - bucket: librdkafka-ci-packages - region: us-west-1 - skip_cleanup: true - local-dir: artifacts - upload-dir: librdkafka/p-librdkafka__bld-travis__plat-${TRAVIS_OS_NAME}__arch-${ARCH}__tag-${TRAVIS_TAG}__sha-${TRAVIS_COMMIT}__bid-${TRAVIS_JOB_NUMBER} - on: - condition: "$CC = gcc" - repo: edenhill/librdkafka - all_branches: true - tags: true http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/7528d23e/thirdparty/librdkafka-0.11.1/CMakeLists.txt ---------------------------------------------------------------------- diff --git a/thirdparty/librdkafka-0.11.1/CMakeLists.txt b/thirdparty/librdkafka-0.11.1/CMakeLists.txt deleted file mode 100644 index 2ae6377..0000000 --- a/thirdparty/librdkafka-0.11.1/CMakeLists.txt +++ /dev/null @@ -1,168 +0,0 @@ -cmake_minimum_required(VERSION 3.4) -project(libRdKafka) - -# Options. No 'RDKAFKA_' prefix to match old C++ code. { - -# This option doesn't affect build in fact, only C code -# (see 'rd_kafka_version_str'). In CMake the build type feature usually used -# (like Debug, Release, etc.). -option(WITHOUT_OPTIMIZATION "Disable optimization" OFF) - -option(ENABLE_DEVEL "Enable development asserts, checks, etc" OFF) -option(ENABLE_REFCNT_DEBUG "Enable refcnt debugging" OFF) -option(ENABLE_SHAREDPTR_DEBUG "Enable sharedptr debugging" OFF) - -# ZLIB { -find_package(ZLIB QUIET) -if(ZLIB_FOUND) - set(with_zlib_default ON) -else() - set(with_zlib_default OFF) -endif() -option(WITH_ZLIB "With ZLIB" ${with_zlib_default}) -# } - -# LibDL { -find_package(LIBDL QUIET) -if(LIBDL_FOUND) - set(with_libdl_default ON) -else() - set(with_libdl_default OFF) -endif() -option(WITH_LIBDL "With LibDL" ${with_libdl_default}) -# } - -# WITH_PLUGINS { -if(WITH_LIBDL) - set(with_plugins_default ON) -else() - set(with_plugins_default OFF) -endif() -option(WITH_PLUGINS "With plugin support" ${with_plugins_default}) -# } - -# OpenSSL { -if(WITH_BUNDLED_SSL) # option from 'h2o' parent project - set(with_ssl_default ON) -else() - find_package(OpenSSL QUIET) - if(OpenSSL_FOUND) - set(with_ssl_default ON) - else() - set(with_ssl_default OFF) - endif() -endif() -option(WITH_SSL "With SSL" ${with_ssl_default}) -# } - -# SASL { -if(WIN32) - set(with_sasl_default ON) -else() - include(FindPkgConfig) - pkg_check_modules(SASL QUIET libsasl2) - if(SASL_FOUND) - set(with_sasl_default ON) - else() - set(with_sasl_default OFF) - endif() -endif() -option(WITH_SASL "With SASL" ${with_sasl_default}) -if(WITH_SASL) - if(WIN32) - set(WITH_SASL_SCRAM ON) - else() - set(WITH_SASL_CYRUS ON) - endif() -endif() -# } - -# } - -option(RDKAFKA_BUILD_EXAMPLES "Build examples" OFF) -option(RDKAFKA_BUILD_TESTS "Build tests" OFF) - -set(TRYCOMPILE_SRC_DIR "${CMAKE_CURRENT_LIST_DIR}/packaging/cmake/try_compile") - -# In: -# * TRYCOMPILE_SRC_DIR -# Out: -# * HAVE_ATOMICS_32 -# * HAVE_ATOMICS_32_SYNC -# * HAVE_ATOMICS_64 -# * HAVE_ATOMICS_64_SYNC -# * HAVE_REGEX -# * HAVE_STRNDUP -# * LINK_ATOMIC -include("packaging/cmake/try_compile/rdkafka_setup.cmake") - -set(GENERATED_DIR "${CMAKE_CURRENT_BINARY_DIR}/generated") - -# In: -# * WITHOUT_OPTIMIZATION -# * ENABLE_DEVEL -# * ENABLE_REFCNT_DEBUG -# * ENABLE_SHAREDPTR_DEBUG -# * HAVE_ATOMICS_32 -# * HAVE_ATOMICS_32_SYNC -# * HAVE_ATOMICS_64 -# * HAVE_ATOMICS_64_SYNC -# * WITH_ZLIB -# * WITH_SSL -# * WITH_SASL -# * HAVE_REGEX -# * HAVE_STRNDUP -configure_file(config.h.in "${GENERATED_DIR}/config.h" @ONLY) - -# Installation (https://github.com/forexample/package-example) { - -include(GNUInstallDirs) - -set(config_install_dir "lib/cmake/${PROJECT_NAME}") - -set(generated_dir "${CMAKE_CURRENT_BINARY_DIR}/generated") - -set(project_config "${generated_dir}/${PROJECT_NAME}Config.cmake") -set(targets_export_name "${PROJECT_NAME}Targets") -set(namespace "${PROJECT_NAME}::") - -include(CMakePackageConfigHelpers) - -# In: -# * targets_export_name -# * PROJECT_NAME -configure_package_config_file( - "packaging/cmake/Config.cmake.in" - "${project_config}" - INSTALL_DESTINATION "${config_install_dir}" -) - -install( - FILES "${project_config}" - DESTINATION "${config_install_dir}" -) - -install( - EXPORT "${targets_export_name}" - NAMESPACE "${namespace}" - DESTINATION "${config_install_dir}" -) - -install( - FILES LICENSES.txt - DESTINATION "share/licenses/librdkafka" -) - -# } - -add_subdirectory(src) -add_subdirectory(src-cpp) - -if(RDKAFKA_BUILD_EXAMPLES) - add_subdirectory(examples) -endif() - -if(RDKAFKA_BUILD_TESTS) - enable_testing() - add_subdirectory(tests) -endif() http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/7528d23e/thirdparty/librdkafka-0.11.1/CONFIGURATION.md ---------------------------------------------------------------------- diff --git a/thirdparty/librdkafka-0.11.1/CONFIGURATION.md b/thirdparty/librdkafka-0.11.1/CONFIGURATION.md deleted file mode 100644 index f58dfbd..0000000 --- a/thirdparty/librdkafka-0.11.1/CONFIGURATION.md +++ /dev/null @@ -1,128 +0,0 @@ -//@file -## Global configuration properties - -Property | C/P | Range | Default | Description ------------------------------------------|-----|-----------------|--------------:|-------------------------- -builtin.features | * | | gzip, snappy, ssl, sasl, regex, lz4, sasl_gssapi, sasl_plain, sasl_scram, plugins | Indicates the builtin features for this build of librdkafka. An application can either query this value or attempt to set it with its list of required features to check for library support. <br>*Type: CSV flags* -client.id | * | | rdkafka | Client identifier. <br>*Type: string* -metadata.broker.list | * | | | Initial list of brokers as a CSV list of broker host or host:port. The application may also use `rd_kafka_brokers_add()` to add brokers during runtime. <br>*Type: string* -bootstrap.servers | * | | | Alias for `metadata.broker.list` -message.max.bytes | * | 1000 .. 1000000000 | 1000000 | Maximum Kafka protocol request message size. <br>*Type: integer* -message.copy.max.bytes | * | 0 .. 1000000000 | 65535 | Maximum size for message to be copied to buffer. Messages larger than this will be passed by reference (zero-copy) at the expense of larger iovecs. <br>*Type: integer* -receive.message.max.bytes | * | 1000 .. 1000000000 | 100000000 | Maximum Kafka protocol response message size. This is a safety precaution to avoid memory exhaustion in case of protocol hickups. The value should be at least fetch.message.max.bytes * number of partitions consumed from + messaging overhead (e.g. 200000 bytes). <br>*Type: integer* -max.in.flight.requests.per.connection | * | 1 .. 1000000 | 1000000 | Maximum number of in-flight requests per broker connection. This is a generic property applied to all broker communication, however it is primarily relevant to produce requests. In particular, note that other mechanisms limit the number of outstanding consumer fetch request per broker to one. <br>*Type: integer* -max.in.flight | * | | | Alias for `max.in.flight.requests.per.connection` -metadata.request.timeout.ms | * | 10 .. 900000 | 60000 | Non-topic request timeout in milliseconds. This is for metadata requests, etc. <br>*Type: integer* -topic.metadata.refresh.interval.ms | * | -1 .. 3600000 | 300000 | Topic metadata refresh interval in milliseconds. The metadata is automatically refreshed on error and connect. Use -1 to disable the intervalled refresh. <br>*Type: integer* -metadata.max.age.ms | * | 1 .. 86400000 | -1 | Metadata cache max age. Defaults to metadata.refresh.interval.ms * 3 <br>*Type: integer* -topic.metadata.refresh.fast.interval.ms | * | 1 .. 60000 | 250 | When a topic loses its leader a new metadata request will be enqueued with this initial interval, exponentially increasing until the topic metadata has been refreshed. This is used to recover quickly from transitioning leader brokers. <br>*Type: integer* -topic.metadata.refresh.fast.cnt | * | 0 .. 1000 | 10 | *Deprecated: No longer used.* <br>*Type: integer* -topic.metadata.refresh.sparse | * | true, false | true | Sparse metadata requests (consumes less network bandwidth) <br>*Type: boolean* -topic.blacklist | * | | | Topic blacklist, a comma-separated list of regular expressions for matching topic names that should be ignored in broker metadata information as if the topics did not exist. <br>*Type: pattern list* -debug | * | generic, broker, topic, metadata, queue, msg, protocol, cgrp, security, fetch, feature, interceptor, plugin, all | | A comma-separated list of debug contexts to enable. Debugging the Producer: broker,topic,msg. Consumer: cgrp,topic,fetch <br>*Type: CSV flags* -socket.timeout.ms | * | 10 .. 300000 | 60000 | Timeout for network requests. <br>*Type: integer* -socket.blocking.max.ms | * | 1 .. 60000 | 1000 | Maximum time a broker socket operation may block. A lower value improves responsiveness at the expense of slightly higher CPU usage. **Deprecated** <br>*Type: integer* -socket.send.buffer.bytes | * | 0 .. 100000000 | 0 | Broker socket send buffer size. System default is used if 0. <br>*Type: integer* -socket.receive.buffer.bytes | * | 0 .. 100000000 | 0 | Broker socket receive buffer size. System default is used if 0. <br>*Type: integer* -socket.keepalive.enable | * | true, false | false | Enable TCP keep-alives (SO_KEEPALIVE) on broker sockets <br>*Type: boolean* -socket.nagle.disable | * | true, false | false | Disable the Nagle algorithm (TCP_NODELAY). <br>*Type: boolean* -socket.max.fails | * | 0 .. 1000000 | 3 | Disconnect from broker when this number of send failures (e.g., timed out requests) is reached. Disable with 0. NOTE: The connection is automatically re-established. <br>*Type: integer* -broker.address.ttl | * | 0 .. 86400000 | 1000 | How long to cache the broker address resolving results (milliseconds). <br>*Type: integer* -broker.address.family | * | any, v4, v6 | any | Allowed broker IP address families: any, v4, v6 <br>*Type: enum value* -reconnect.backoff.jitter.ms | * | 0 .. 3600000 | 500 | Throttle broker reconnection attempts by this value +-50%. <br>*Type: integer* -statistics.interval.ms | * | 0 .. 86400000 | 0 | librdkafka statistics emit interval. The application also needs to register a stats callback using `rd_kafka_conf_set_stats_cb()`. The granularity is 1000ms. A value of 0 disables statistics. <br>*Type: integer* -enabled_events | * | 0 .. 2147483647 | 0 | See `rd_kafka_conf_set_events()` <br>*Type: integer* -error_cb | * | | | Error callback (set with rd_kafka_conf_set_error_cb()) <br>*Type: pointer* -throttle_cb | * | | | Throttle callback (set with rd_kafka_conf_set_throttle_cb()) <br>*Type: pointer* -stats_cb | * | | | Statistics callback (set with rd_kafka_conf_set_stats_cb()) <br>*Type: pointer* -log_cb | * | | | Log callback (set with rd_kafka_conf_set_log_cb()) <br>*Type: pointer* -log_level | * | 0 .. 7 | 6 | Logging level (syslog(3) levels) <br>*Type: integer* -log.queue | * | true, false | false | Disable spontaneous log_cb from internal librdkafka threads, instead enqueue log messages on queue set with `rd_kafka_set_log_queue()` and serve log callbacks or events through the standard poll APIs. **NOTE**: Log messages will linger in a temporary queue until the log queue has been set. <br>*Type: boolean* -log.thread.name | * | true, false | true | Print internal thread name in log messages (useful for debugging librdkafka internals) <br>*Type: boolean* -log.connection.close | * | true, false | true | Log broker disconnects. It might be useful to turn this off when interacting with 0.9 brokers with an aggressive `connection.max.idle.ms` value. <br>*Type: boolean* -socket_cb | * | | | Socket creation callback to provide race-free CLOEXEC <br>*Type: pointer* -connect_cb | * | | | Socket connect callback <br>*Type: pointer* -closesocket_cb | * | | | Socket close callback <br>*Type: pointer* -open_cb | * | | | File open callback to provide race-free CLOEXEC <br>*Type: pointer* -opaque | * | | | Application opaque (set with rd_kafka_conf_set_opaque()) <br>*Type: pointer* -default_topic_conf | * | | | Default topic configuration for automatically subscribed topics <br>*Type: pointer* -internal.termination.signal | * | 0 .. 128 | 0 | Signal that librdkafka will use to quickly terminate on rd_kafka_destroy(). If this signal is not set then there will be a delay before rd_kafka_wait_destroyed() returns true as internal threads are timing out their system calls. If this signal is set however the delay will be minimal. The application should mask this signal as an internal signal handler is installed. <br>*Type: integer* -api.version.request | * | true, false | true | Request broker's supported API versions to adjust functionality to available protocol features. If set to false, or the ApiVersionRequest fails, the fallback version `broker.version.fallback` will be used. **NOTE**: Depends on broker version >=0.10.0. If the request is not supported by (an older) broker the `broker.version.fallback` fallback is used. <br>*Type: boolean* -api.version.request.timeout.ms | * | 1 .. 300000 | 10000 | Timeout for broker API version requests. <br>*Type: integer* -api.version.fallback.ms | * | 0 .. 604800000 | 1200000 | Dictates how long the `broker.version.fallback` fallback is used in the case the ApiVersionRequest fails. **NOTE**: The ApiVersionRequest is only issued when a new connection to the broker is made (such as after an upgrade). <br>*Type: integer* -broker.version.fallback | * | | 0.9.0 | Older broker versions (<0.10.0) provides no way for a client to query for supported protocol features (ApiVersionRequest, see `api.version.request`) making it impossible for the client to know what features it may use. As a workaround a user may set this property to the expected broker version and the client will automatically adjust its feature set accordingly if the ApiVersionRequest fails (or is disabled). The fallback broker version will be used for `api.version.fallback.ms`. Valid values are: 0.9.0, 0.8.2, 0.8.1, 0.8.0. Any other value, such as 0.10.2.1, enables ApiVersionRequests. <br>*Type: string* -security.protocol | * | plaintext, ssl, sasl_plaintext, sasl_ssl | plaintext | Protocol used to communicate with brokers. <br>*Type: enum value* -ssl.cipher.suites | * | | | A cipher suite is a named combination of authentication, encryption, MAC and key exchange algorithm used to negotiate the security settings for a network connection using TLS or SSL network protocol. See manual page for `ciphers(1)` and `SSL_CTX_set_cipher_list(3). <br>*Type: string* -ssl.key.location | * | | | Path to client's private key (PEM) used for authentication. <br>*Type: string* -ssl.key.password | * | | | Private key passphrase <br>*Type: string* -ssl.certificate.location | * | | | Path to client's public key (PEM) used for authentication. <br>*Type: string* -ssl.ca.location | * | | | File or directory path to CA certificate(s) for verifying the broker's key. <br>*Type: string* -ssl.crl.location | * | | | Path to CRL for verifying broker's certificate validity. <br>*Type: string* -sasl.mechanisms | * | | GSSAPI | SASL mechanism to use for authentication. Supported: GSSAPI, PLAIN, SCRAM-SHA-256, SCRAM-SHA-512. **NOTE**: Despite the name only one mechanism must be configured. <br>*Type: string* -sasl.kerberos.service.name | * | | kafka | Kerberos principal name that Kafka runs as. <br>*Type: string* -sasl.kerberos.principal | * | | kafkaclient | This client's Kerberos principal name. <br>*Type: string* -sasl.kerberos.kinit.cmd | * | | kinit -S "%{sasl.kerberos.service.name}/%{broker.name}" -k -t "%{sasl.kerberos.keytab}" %{sasl.kerberos.principal} | Full kerberos kinit command string, %{config.prop.name} is replaced by corresponding config object value, %{broker.name} returns the broker's hostname. <br>*Type: string* -sasl.kerberos.keytab | * | | | Path to Kerberos keytab file. Uses system default if not set.**NOTE**: This is not automatically used but must be added to the template in sasl.kerberos.kinit.cmd as ` ... -t %{sasl.kerberos.keytab}`. <br>*Type: string* -sasl.kerberos.min.time.before.relogin | * | 1 .. 86400000 | 60000 | Minimum time in milliseconds between key refresh attempts. <br>*Type: integer* -sasl.username | * | | | SASL username for use with the PLAIN and SASL-SCRAM-.. mechanisms <br>*Type: string* -sasl.password | * | | | SASL password for use with the PLAIN and SASL-SCRAM-.. mechanism <br>*Type: string* -plugin.library.paths | * | | | List of plugin libaries to load (; separated). The library search path is platform dependent (see dlopen(3) for Unix and LoadLibrary() for Windows). If no filename extension is specified the platform-specific extension (such as .dll or .so) will be appended automatically. <br>*Type: string* -interceptors | * | | | Interceptors added through rd_kafka_conf_interceptor_add_..() and any configuration handled by interceptors. <br>*Type: * -group.id | * | | | Client group id string. All clients sharing the same group.id belong to the same group. <br>*Type: string* -partition.assignment.strategy | * | | range,roundrobin | Name of partition assignment strategy to use when elected group leader assigns partitions to group members. <br>*Type: string* -session.timeout.ms | * | 1 .. 3600000 | 30000 | Client group session and failure detection timeout. <br>*Type: integer* -heartbeat.interval.ms | * | 1 .. 3600000 | 1000 | Group session keepalive heartbeat interval. <br>*Type: integer* -group.protocol.type | * | | consumer | Group protocol type <br>*Type: string* -coordinator.query.interval.ms | * | 1 .. 3600000 | 600000 | How often to query for the current client group coordinator. If the currently assigned coordinator is down the configured query interval will be divided by ten to more quickly recover in case of coordinator reassignment. <br>*Type: integer* -enable.auto.commit | C | true, false | true | Automatically and periodically commit offsets in the background. <br>*Type: boolean* -auto.commit.interval.ms | C | 0 .. 86400000 | 5000 | The frequency in milliseconds that the consumer offsets are committed (written) to offset storage. (0 = disable). This setting is used by the high-level consumer. <br>*Type: integer* -enable.auto.offset.store | C | true, false | true | Automatically store offset of last message provided to application. <br>*Type: boolean* -queued.min.messages | C | 1 .. 10000000 | 100000 | Minimum number of messages per topic+partition librdkafka tries to maintain in the local consumer queue. <br>*Type: integer* -queued.max.messages.kbytes | C | 1 .. 1000000000 | 1000000 | Maximum number of kilobytes per topic+partition in the local consumer queue. This value may be overshot by fetch.message.max.bytes. This property has higher priority than queued.min.messages. <br>*Type: integer* -fetch.wait.max.ms | C | 0 .. 300000 | 100 | Maximum time the broker may wait to fill the response with fetch.min.bytes. <br>*Type: integer* -fetch.message.max.bytes | C | 1 .. 1000000000 | 1048576 | Initial maximum number of bytes per topic+partition to request when fetching messages from the broker. If the client encounters a message larger than this value it will gradually try to increase it until the entire message can be fetched. <br>*Type: integer* -max.partition.fetch.bytes | C | | | Alias for `fetch.message.max.bytes` -fetch.min.bytes | C | 1 .. 100000000 | 1 | Minimum number of bytes the broker responds with. If fetch.wait.max.ms expires the accumulated data will be sent to the client regardless of this setting. <br>*Type: integer* -fetch.error.backoff.ms | C | 0 .. 300000 | 500 | How long to postpone the next fetch request for a topic+partition in case of a fetch error. <br>*Type: integer* -offset.store.method | C | none, file, broker | broker | Offset commit store method: 'file' - local file store (offset.store.path, et.al), 'broker' - broker commit store (requires Apache Kafka 0.8.2 or later on the broker). <br>*Type: enum value* -consume_cb | C | | | Message consume callback (set with rd_kafka_conf_set_consume_cb()) <br>*Type: pointer* -rebalance_cb | C | | | Called after consumer group has been rebalanced (set with rd_kafka_conf_set_rebalance_cb()) <br>*Type: pointer* -offset_commit_cb | C | | | Offset commit result propagation callback. (set with rd_kafka_conf_set_offset_commit_cb()) <br>*Type: pointer* -enable.partition.eof | C | true, false | true | Emit RD_KAFKA_RESP_ERR__PARTITION_EOF event whenever the consumer reaches the end of a partition. <br>*Type: boolean* -check.crcs | C | true, false | false | Verify CRC32 of consumed messages, ensuring no on-the-wire or on-disk corruption to the messages occurred. This check comes at slightly increased CPU usage. <br>*Type: boolean* -queue.buffering.max.messages | P | 1 .. 10000000 | 100000 | Maximum number of messages allowed on the producer queue. <br>*Type: integer* -queue.buffering.max.kbytes | P | 1 .. 2097151 | 4000000 | Maximum total message size sum allowed on the producer queue. This property has higher priority than queue.buffering.max.messages. <br>*Type: integer* -queue.buffering.max.ms | P | 0 .. 900000 | 0 | Delay in milliseconds to wait for messages in the producer queue to accumulate before constructing message batches (MessageSets) to transmit to brokers. A higher value allows larger and more effective (less overhead, improved compression) batches of messages to accumulate at the expense of increased message delivery latency. <br>*Type: integer* -linger.ms | P | | | Alias for `queue.buffering.max.ms` -message.send.max.retries | P | 0 .. 10000000 | 2 | How many times to retry sending a failing MessageSet. **Note:** retrying may cause reordering. <br>*Type: integer* -retries | P | | | Alias for `message.send.max.retries` -retry.backoff.ms | P | 1 .. 300000 | 100 | The backoff time in milliseconds before retrying a message send. <br>*Type: integer* -compression.codec | P | none, gzip, snappy, lz4 | none | compression codec to use for compressing message sets. This is the default value for all topics, may be overriden by the topic configuration property `compression.codec`. <br>*Type: enum value* -batch.num.messages | P | 1 .. 1000000 | 10000 | Maximum number of messages batched in one MessageSet. The total MessageSet size is also limited by message.max.bytes. <br>*Type: integer* -delivery.report.only.error | P | true, false | false | Only provide delivery reports for failed messages. <br>*Type: boolean* -dr_cb | P | | | Delivery report callback (set with rd_kafka_conf_set_dr_cb()) <br>*Type: pointer* -dr_msg_cb | P | | | Delivery report callback (set with rd_kafka_conf_set_dr_msg_cb()) <br>*Type: pointer* - - -## Topic configuration properties - -Property | C/P | Range | Default | Description ------------------------------------------|-----|-----------------|--------------:|-------------------------- -request.required.acks | P | -1 .. 1000 | 1 | This field indicates how many acknowledgements the leader broker must receive from ISR brokers before responding to the request: *0*=Broker does not send any response/ack to client, *1*=Only the leader broker will need to ack the message, *-1* or *all*=broker will block until message is committed by all in sync replicas (ISRs) or broker's `in.sync.replicas` setting before sending response. <br>*Type: integer* -acks | P | | | Alias for `request.required.acks` -request.timeout.ms | P | 1 .. 900000 | 5000 | The ack timeout of the producer request in milliseconds. This value is only enforced by the broker and relies on `request.required.acks` being != 0. <br>*Type: integer* -message.timeout.ms | P | 0 .. 900000 | 300000 | Local message timeout. This value is only enforced locally and limits the time a produced message waits for successful delivery. A time of 0 is infinite. <br>*Type: integer* -produce.offset.report | P | true, false | false | Report offset of produced message back to application. The application must be use the `dr_msg_cb` to retrieve the offset from `rd_kafka_message_t.offset`. <br>*Type: boolean* -partitioner_cb | P | | | Partitioner callback (set with rd_kafka_topic_conf_set_partitioner_cb()) <br>*Type: pointer* -opaque | * | | | Application opaque (set with rd_kafka_topic_conf_set_opaque()) <br>*Type: pointer* -compression.codec | P | none, gzip, snappy, lz4, inherit | inherit | Compression codec to use for compressing message sets. <br>*Type: enum value* -auto.commit.enable | C | true, false | true | If true, periodically commit offset of the last message handed to the application. This committed offset will be used when the process restarts to pick up where it left off. If false, the application will have to call `rd_kafka_offset_store()` to store an offset (optional). **NOTE:** This property should only be used with the simple legacy consumer, when using the high-level KafkaConsumer the global `enable.auto.commit` property must be used instead. **NOTE:** There is currently no zookeeper integration, offsets will be written to broker or local file according to offset.store.method. <br>*Type: boolean* -enable.auto.commit | C | | | Alias for `auto.commit.enable` -auto.commit.interval.ms | C | 10 .. 86400000 | 60000 | The frequency in milliseconds that the consumer offsets are committed (written) to offset storage. This setting is used by the low-level legacy consumer. <br>*Type: integer* -auto.offset.reset | C | smallest, earliest, beginning, largest, latest, end, error | largest | Action to take when there is no initial offset in offset store or the desired offset is out of range: 'smallest','earliest' - automatically reset the offset to the smallest offset, 'largest','latest' - automatically reset the offset to the largest offset, 'error' - trigger an error which is retrieved by consuming messages and checking 'message->err'. <br>*Type: enum value* -offset.store.path | C | | . | Path to local file for storing offsets. If the path is a directory a filename will be automatically generated in that directory based on the topic and partition. <br>*Type: string* -offset.store.sync.interval.ms | C | -1 .. 86400000 | -1 | fsync() interval for the offset file, in milliseconds. Use -1 to disable syncing, and 0 for immediate sync after each write. <br>*Type: integer* -offset.store.method | C | file, broker | broker | Offset commit store method: 'file' - local file store (offset.store.path, et.al), 'broker' - broker commit store (requires "group.id" to be configured and Apache Kafka 0.8.2 or later on the broker.). <br>*Type: enum value* -consume.callback.max.messages | C | 0 .. 1000000 | 0 | Maximum number of messages to dispatch in one `rd_kafka_consume_callback*()` call (0 = unlimited) <br>*Type: integer* - -### C/P legend: C = Consumer, P = Producer, * = both http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/7528d23e/thirdparty/librdkafka-0.11.1/CONTRIBUTING.md ---------------------------------------------------------------------- diff --git a/thirdparty/librdkafka-0.11.1/CONTRIBUTING.md b/thirdparty/librdkafka-0.11.1/CONTRIBUTING.md deleted file mode 100644 index 5da7c77..0000000 --- a/thirdparty/librdkafka-0.11.1/CONTRIBUTING.md +++ /dev/null @@ -1,271 +0,0 @@ -# Contributing to librdkafka - -(This document is based on [curl's CONTRIBUTE.md](https://github.com/curl/curl/blob/master/docs/CONTRIBUTE.md) - thank you!) - -This document is intended to offer guidelines on how to best contribute to the -librdkafka project. This concerns new features as well as bug fixes and -general improvements. - -### License and copyright - -When contributing with code, you agree to put your changes and new code under -the same license librdkafka is already using unless stated and agreed -otherwise. - -When changing existing source code, you do not alter the copyright of the -original file(s). The copyright will still be owned by the original creator(s) -or those who have been assigned copyright by the original author(s). - -By submitting a patch to the librdkafka, you are assumed to have the right -to the code and to be allowed by your employer or whatever to hand over that -patch/code to us. We will credit you for your changes as far as possible, to -give credit but also to keep a trace back to who made what changes. Please -always provide us with your full real name when contributing! - -Official librdkafka project maintainer(s) assume ownership of all accepted -submissions. - -## Write a good patch - -### Follow code style - -When writing C code, follow the code style already established in -the project. Consistent style makes code easier to read and mistakes less -likely to happen. - -See the end of this document for the C style guide to use in librdkafka. - - -### Write Separate Changes - -It is annoying when you get a huge patch from someone that is said to fix 511 -odd problems, but discussions and opinions don't agree with 510 of them - or -509 of them were already fixed in a different way. Then the person merging -this change needs to extract the single interesting patch from somewhere -within the huge pile of source, and that gives a lot of extra work. - -Preferably, each fix that correct a problem should be in its own patch/commit -with its own description/commit message stating exactly what they correct so -that all changes can be selectively applied by the maintainer or other -interested parties. - -Also, separate changes enable bisecting much better when we track problems -and regression in the future. - -### Patch Against Recent Sources - -Please try to make your patches against latest master branch. - -### Test Cases - -Bugfixes should also include a new test case in the regression test suite -that verifies the bug is fixed. -Create a new tests/00<freenumber>-<short_bug_description>.c file and -try to reproduce the issue in its most simple form. -Verify that the test case fails for earlier versions and passes with your -bugfix in-place. - -New features and APIs should also result in an added test case. - -Submitted patches must pass all existing tests. -For more information on the test suite see [tests/README] - - - -## How to get your changes into the main sources - -File a [pull request on github](https://github.com/edenhill/librdkafka/pulls) - -Your change will be reviewed and discussed there and you will be -expected to correct flaws pointed out and update accordingly, or the change -risk stalling and eventually just get deleted without action. As a submitter -of a change, you are the owner of that change until it has been merged. - -Make sure to monitor your PR on github and answer questions and/or -fix nits/flaws. This is very important. We will take lack of replies as a -sign that you're not very anxious to get your patch accepted and we tend to -simply drop such changes. - -When you adjust your pull requests after review, please squash the -commits so that we can review the full updated version more easily -and keep history cleaner. - -For example: - - # Interactive rebase to let you squash/fixup commits - $ git rebase -i master - - # Mark fixes-on-fixes commits as 'fixup' (or just 'f') in the - # first column. These will be silently integrated into the - # previous commit, so make sure to move the fixup-commit to - # the line beneath the parent commit. - - # Since this probably rewrote the history of previously pushed - # commits you will need to make a force push, which is usually - # a bad idea but works good for pull requests. - $ git push --force origin your_feature_branch - - -### Write good commit messages - -A short guide to how to write commit messages in the curl project. - - ---- start ---- - [area]: [short line describing the main effect] [(#issuenumber)] - -- empty line -- - [full description, no wider than 72 columns that describe as much as - possible as to why this change is made, and possibly what things - it fixes and everything else that is related] - ---- stop ---- - -Example: - - cgrp: restart query timer on all heartbeat failures (#10023) - - If unhandled errors were received in HeartbeatResponse - the cgrp could get stuck in a state where it would not - refresh its coordinator. - - - -# librdkafka C style guide - -## Function and globals naming - -Use self-explanatory hierarchical snake-case naming. -Pretty much all symbols should start with `rd_kafka_`, followed by -their subsystem (e.g., `cgrp`, `broker`, `buf`, etc..), followed by an -action (e.g, `find`, `get`, `clear`, ..). - - -## Variable naming - -For existing types use the type prefix as variable name. -The type prefix is typically the first part of struct member fields. -Example: - - * `rd_kafka_broker_t` has field names starting with `rkb_..`, thus broker - variable names should be named `rkb` - - -For other types use reasonably concise but descriptive names. -`i` and `j` are typical int iterators. - -## Variable declaration - -Variables must be declared at the head of a scope, no in-line variable -declarations are allowed. - -## Indenting - -Use 8 spaces indent, same as the Linux kernel. -In emacs, use `c-set-style "linux`. -For C++, use Google's C++ style. - -## Comments - -Use `/* .. */` comments, not `// ..` - -For functions, use doxygen syntax, e.g.: - - /** - * @brief <short description> - * .. - * @returns <something..> - */ - - -Make sure to comment non-obvious code and situations where the full -context of an operation is not easily graspable. - -Also make sure to update existing comments when the code changes. - - -## Line length - -Try hard to keep line length below 80 characters, when this is not possible -exceed it with reason. - - -## Braces - -Braces go on the same line as their enveloping statement: - - int some_func (..) { - while (1) { - if (1) { - do something; - .. - } else { - do something else; - .. - } - } - - /* Single line scopes should not have braces */ - if (1) - hi(); - else if (2) - /* Say hello */ - hello(); - else - bye(); - - -## Spaces - -All expression parentheses should be prefixed and suffixed with a single space: - - int some_func (int a) { - - if (1) - ....; - - for (i = 0 ; i < 19 ; i++) { - - - } - } - - -Use space around operators: - - int a = 2; - - if (b >= 3) - c += 2; - -Except for these: - - d++; - --e; - - -## New block on new line - -New blocks should be on a new line: - - if (1) - new(); - else - old(); - - -## Parentheses - -Don't assume the reader knows C operator precedence by heart for complex -statements, add parentheses to ease readability. - - -## ifdef hell - -Avoid ifdef's as much as possible. -Platform support checking should be performed in configure.librdkafka. - - - - - -# librdkafka C++ style guide - -Follow [Google's C++ style guide](https://google.github.io/styleguide/cppguide.html)
