sarama

0열

1답변

Kafka 0.11 클러스터에 연결하는 Go 응용 프로그램이 응답의 Timestamp 값이없는 라이브러리의 0.8.2 버전을 사용하고 있다는 것을 알게되었습니다. 그런 다음 Kafka 0.11.x API/버전이 지원되지 않는다는 것을 알았지 만 (그러나 그들은 그것에 대해 연구 중입니다). 저는 현재 두 가지 해결책을 가지고 있습니다. 먼저 내 앱에서 필수

0열

1답변

Docker

에 배포 할 때 Golang 패닉에 구현 된 Apache Kafka 소비자는 kafka 서버에서 메시지를 읽고 HTTP를 통해 보내는 간단한 마이크로 서비스를 구현하려는 시도입니다. 내가 터미널에서 실행하면 잘 작동하지만에 배치 때 panic: runtime error: invalid memory address or nil pointer dereferenc

1열

1답변

Golang Kafka 10에서 GroupID를 얻는 방법?

카프카 10.0 및 https://github.com/Shopify/sarama을 사용하고 있습니다. 소비자가 처리 한 최신 메시지의 오프셋을 가져 오려고합니다. 이렇게하려면 그룹 이름이 필요한 NewOffsetManagerFromClient(group string, client Client) 메서드를 찾았습니다. 소비자 그룹 이름을 얻으려면 어떻게해야합니

0열

1답변

Golang에서 kafka 소비자 그룹을 만드는 방법은 무엇입니까?

사용 가능한 라이브러리는 sarama (또는 해당 확장자 sarama-cluster)이지만 sarama이나 sarama-cluster이 아닌 소비자 그룹 예제는 제공되지 않습니다. API를 이해할 수 없습니다. 주제에 대한 소비자 그룹을 생성하는 예가 있습니까?

0열

2답변

카프카에서 새로운 주제가 만들어 졌음을 소비자에게 알리는 방법은 무엇입니까?

저는 소비를 동적으로 업데이트하려고 노력 중입니다. 동물을 사용하여보다 구체적인 예를 들어 보겠습니다. 내가 애완 동물 상점을 가지고 있다고 상상해보십시오. 모든 주제는 동물 (예 : 개, 고양이, 물고기)의 유형입니다. 카프카 소비자의 주요 책임은 카프카에있는 모든 기록/기록/메시지를 수집하여 데이터베이스에 저장하는 것입니다. 내 소비자가 dogs 및 c

2열

1답변

sarama-cluster의 NewConsumer를 조롱

실제 브로커를 설정하지 않고 sarama-cluster의 NewConsumer 기능을 테스트/모의 할 수있는 방법이 있습니까? 내가 여기서 무엇을 놓치고 있니? 코드 내가 테스트를 시도하고는 : import cluster "github.com/bsm/sarama-cluster" func initSaramaConsumer() (*cluster.Consum