如何使用confluent-kafka-python從Data Science Experience/Spark即服務連接到Message Hub？

的Bluemix MessageHub文檔點蟒用戶匯合卡夫卡庫：如何使用confluent-kafka-python從Data Science Experience/Spark即服務連接到Message Hub？

所以我試圖安裝：

!pip install --user confluent-kafka

不過，我已經打了這個錯誤：

Collecting confluent-kafka 
    Using cached confluent-kafka-0.9.1.2.tar.gz 
Installing collected packages: confluent-kafka 
    Running setup.py install for confluent-kafka ... - \ error 
    Complete output from command /usr/local/src/bluemix_jupyter_bundle.v22/notebook/bin/python -u -c "import setuptools, tokenize;__file__='/gpfs/global_fs01/sym_shared/YPProdSpark/user/xxxx/notebook/tmp/pip-build-N3zDUh/confluent-kafka/setup.py';exec(compile(getattr(tokenize, 'open', open)(__file__).read().replace('\r\n', '\n'), __file__, 'exec'))" install --record /gpfs/fs01/user/xxxx/notebook/tmp/pip-PyAwq2-record/install-record.txt --single-version-externally-managed --compile --user --prefix=: 
    running install 
    running build 
    running build_py 
    creating build 
    creating build/lib.linux-x86_64-2.7 
    creating build/lib.linux-x86_64-2.7/confluent_kafka 
    copying confluent_kafka/__init__.py -> build/lib.linux-x86_64-2.7/confluent_kafka 
    creating build/lib.linux-x86_64-2.7/confluent_kafka/kafkatest 
    copying confluent_kafka/kafkatest/__init__.py -> build/lib.linux-x86_64-2.7/confluent_kafka/kafkatest 
    copying confluent_kafka/kafkatest/verifiable_consumer.py -> build/lib.linux-x86_64-2.7/confluent_kafka/kafkatest 
    copying confluent_kafka/kafkatest/verifiable_producer.py -> build/lib.linux-x86_64-2.7/confluent_kafka/kafkatest 
    copying confluent_kafka/kafkatest/verifiable_client.py -> build/lib.linux-x86_64-2.7/confluent_kafka/kafkatest 
    running build_ext 
    building 'confluent_kafka.cimpl' extension 
    creating build/temp.linux-x86_64-2.7 
    creating build/temp.linux-x86_64-2.7/confluent_kafka 
    creating build/temp.linux-x86_64-2.7/confluent_kafka/src 
    gcc -pthread -fno-strict-aliasing -g -O2 -DNDEBUG -g -fwrapv -O3 -Wall -Wstrict-prototypes -fPIC -I/usr/local/src/bluemix_jupyter_bundle.v22/notebook/include/python2.7 -c confluent_kafka/src/confluent_kafka.c -o build/temp.linux-x86_64-2.7/confluent_kafka/src/confluent_kafka.o 
    In file included from confluent_kafka/src/confluent_kafka.c:17:0: 
    confluent_kafka/src/confluent_kafka.h:20:32: fatal error: librdkafka/rdkafka.h: No such file or directory 
    #include <librdkafka/rdkafka.h> 
            ^
    compilation terminated. 
    error: command 'gcc' failed with exit status 1 

    ---------------------------------------- 
Command "/usr/local/src/bluemix_jupyter_bundle.v22/notebook/bin/python -u -c "import setuptools, tokenize;__file__='/gpfs/global_fs01/sym_shared/YPProdSpark/user/xxxx/notebook/tmp/pip-build-N3zDUh/confluent-kafka/setup.py';exec(compile(getattr(tokenize, 'open', open)(__file__).read().replace('\r\n', '\n'), __file__, 'exec'))" install --record /gpfs/fs01/user/xxxx/notebook/tmp/pip-PyAwq2-record/install-record.txt --single-version-externally-managed --compile --user --prefix=" failed with error code 1 in /gpfs/global_fs01/sym_shared/YPProdSpark/user/xxxx/notebook/tmp/pip-build-N3zDUh/confluent-kafka/

來源

2016-10-30 Chris Snow

請注意，我是安倍使用可替代卡夫卡Python庫HTTP連接： //sackoverflow.com/a/40325181/1033422 –

根據融合readme，您需要安裝librdkafka本機庫，然後才能將u選擇他們的Python客戶端。

，正如你在其他評論中發現他們是替代純Python庫kafka-python，你可能會發現更容易使用的Bluemix應用

來源

2016-10-30 10:17:46

我認爲我的主要問題是，作爲服務沒有提供其姊妹服務messagehub推薦的驅動程序的火花。我想這是因爲火花流對python支持sasl的kafka不可用，所以這會限制用於連接messagehub的用例，而不僅僅是驅動主機上運行的程序。 –

如何使用confluent-kafka-python從Data Science Experience/Spark即服務連接到Message Hub？

回答

相關問題