SOA 응용 프로그램에서 다음과 같은 시나리오가 있습니다. ServiceA는 ServiceB의 인스턴스에 의해 비동기 적으로 처리되어야하는 일부 작업을 생성합니다. 기본적으로 이는 각 작업자가 ServiceB의 인스턴스 인 작업 대기열 문제로 변환됩니다. 우리는 메시지 브로커로 Kafka를 사용하고 있으며 다음과 같은 설정을합니다. 5 브로커 B1, B2,
kafka 상위 소비자를 사용하고 있습니다. 소비자를 시작하면 새로운 메시지가 모두 발견됩니다. Java kafka 제작자를 사용하여 새로운 메시지를 찾습니다. 그러나 잠시 후 계속 반복되지만 새 메시지는 없습니다. 디버거에서 실행을 일시 중지하면 소비자가 갑자기 메시지를 찾기 시작합니다. Java에서 버전 0.8.0을 사용하고 있습니다. 오류가 발생하면
처음부터 시작하겠습니다. openSuse 13.2, jdk_1.7.0_51, scala-2.11.4 및 gradle-2.2.1도 있습니다. kafka-0.8.2-bet-src의 소스를 다운로드하고 readme 파일에 쓰여진대로 ./gradlew 명령을 실행합니다. 테스트를 제외하고 성공한 모든 명령 (93 % 성공한 경우, 19 실패) btw 나는 rele
저는 EC2 서버에서 1k 크기의 메시지를 스트리밍하여 카프카 0.8.1.1을 벤치마킹합니다. 나는 두 m3.xlarge 서버에 사육사를 설치 한 다음 구성했다 : 나는 각각의 디스크로 분할 32GB의 RAM 및 추가 6 개 SSD 드라이브와 i2.2xlarge 시스템에서 단일 카프카 서버를 설치 dataDir=/var/zookeeper/
소비자가 메시지를 읽고 스레드가 메시지를 다른 항목으로 생성하기 전에 데이터베이스 액세스를 포함하여 여러 가지 작업을 수행하는 응용 프로그램이 있습니다. 스레드에서 메시지를 소비하고 생성하는 시간은 몇 분이 소요될 수 있습니다. 메시지가 새로운 주제로 생성되면 커밋이 완료되어 소비자 대기열 메시지에 대한 작업이 완료되었음을 나타냅니다. 자동 커밋이 비활성화