message-hub

1열

2답변

Bluemix Message Hub - SASL 인증을 초기화하는 데 실패했지만 여전히 작동하는 것 같습니다.

Bluemix Message Hub를 Python과 함께 사용하려고하면 오류 및 실패가 계속 발생합니다. 왜 아래에 주어진 아이디어? 오류가 "SASL 인증을 초기화하지 못했습니다 : SASL 핸드 셰이크가 (메커니즘 PLAIN에서 요구하는) 브로커가 지원되지"하는 내 생산자와 소비자를 실행할 때 그러나, 그들은 작동하는 것. 메시지가 생성되고 메시지가 소

1열

1답변

PublishKafka 프로세서를 통해 NIFI를 IBM MessageHub에 어떻게 연결합니까?

NIFI를 IBM MessageHub에 연결하려고하는데 연결이 작동하지 않습니다. 누구나 구성하는 방법에 대한 예제가 있습니까? 게시판에 시간 초과 예외가 발생합니다. PublishKafka_0_11 1.4.0 프로세서을 구성했습니다. SASL_SSL로 구성된 표준 SSL 콘텍스트 서비스를 추가 jaas.conf를 KafkaClient { org.apac

0열

1답변

IBM Message Hub에 연결하는 kafka 입력 플러그인의 복구 할 수없는 오류

logstash의 IBM Message Hub를 사용하려고합니다. 내 logstash.conf 다음 Message Hub Consumer example을 바탕으로 input { kafka { bootstrap_servers => "kafka04-prod01.messagehub.services.eu-de.bluemix.net:9093,ka

0열

1답변

카프카 소비자가 3 개 이상의 주제를 구독 할 때 메시지를받지 못함

node-rdkafka (https://github.com/Blizzard/node-rdkafka)를 사용하여 IBM Bluemix Message Hub에서 메시지를 생성하고 생성했습니다. 노드 프로세스 당 최대 2 개의 주제에 대해서만 구독하는 한 문제없이 메시지를 소비하고 생성 할 수 있습니다. 3 개 이상의 주제를 구독하자마자 내 소비자는 가입 된 주

0열

1답변

kafka python - Bluemix MessageHub - ConnectionError : 소켓 연결이 끊어졌습니다.

kafka python 클라이언트를 사용하여 Message Hub에 메시지를 푸시하지만 MessageHub으로 메시지를 보내는 것을 중단하는 것으로 나타났습니다. 내가 retries=5를 추가하려면 코드를 업데이트 ConnectionError: socket disconnected : from kafka import KafkaProducer from k

0열

1답변

카프카 Golang 클라이언트는이 코드 내가 실행 해요 어떤 조각입니다 메시지 허브 서비스

에 연결하는 데 실패합니다. 이 문제는이 문제에 링크 될 수 있다면가 'SSL handshake failed: /SourceCache/OpenSSL098/OpenSSL098-52.40.1/src/ssl/s23_clnt.c:593: error:1407742E:SSL routines:SSL23_GET_SERVER_HELLO:tlsv1 alert protocol

0열

1답변

IBM Message Hub에서 주제를 만들려고 할 때 403 Unauthorized가되는 이유

Bluemix에서 IBM Message Hub의 새 인스턴스를 만들고 Kafka Java 클라이언트를 사용하여 (내 랩톱에서) 연결하고 목록에 추가 할 수 있습니다 주제 내가 하지 수있는 것은 (바꿈이 명확성을 위해 추가) 관리 REST API를 통해 항목을 만들 수 있습니다 : curl -H "Content-Type: application/json"

1열

1답변

Kafka enable.auto.commit을 false로 설정했지만 여전히 "다음"메시지를 가져옵니다.

내 소비자가 레코드를 성공적으로 처리했을 때 Kafka에게 알려서 enable.auto.commit을 false로 설정하여 자동 커밋을 해제했습니다. 오프셋 0과 1에서 구독하는 주제에 대해 두 개의 메시지가 있고 poll에 대한 각 호출이 최대 레코드 (max.poll.records을 1로 설정)로 반환하도록 소비자를 생성했습니다. 이제 consumer.

0열

1답변

IBM Cloud Object Storage에 대한 Message-Hub Bridge 작성

Message Hub에서 S3 Object Storage로 "자격 증명"의 정보를 복사하는 "Bridge"를 만들려고하지만 "페이지를 새로 고치거나 Bluemix에 다시 로그인하십시오. " 나는이 자격 증명과 대상으로 사용하려는 버킷에 대한 액세스 정책을 이미 만들었습니다. 또한 개인 및 공개 엔드 포인트로 시도되었습니다. 이 작업을 수행하는 방법을 설명하

0열

1답변

메시지 허브에서 서비스 자격 증명을 사용자 지정하는 방법

bluemix에서 메시지 허브 인스턴스를 만들면 화면에 서비스 자격 증명 탭이 표시됩니다. "사용자": "XXXXXXXXXXXXXXXX" "비밀"데이터는 JSON 형식으로하고 편집 할 수 없습니다 "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx" 사용자 이름과 암호를 지정하거나 편집 할 수있는 방법이 있습니까?