Sarama를 사용하여 Golang Kafka 10에서 소비자 그룹 오프셋을 검색하는 방법은 무엇입니까?

Golang Kafka 10에서 소비자 그룹 오프셋 액세스

Kafka 10을 사용한 Golang Kafka 라이브러리(sarama)의 발전으로 네이티브 소비자 그룹이 도입되었습니다. 기능. 이는 소비자 그룹에서 처리 중인 현재 메시지 오프셋을 검색하는 방법에 대한 질문을 제기합니다.

해결책:

이러한 요구를 해결하기 위해 sarama 라이브러리는 메커니즘을 제공합니다. 소비자 그룹 오프셋에 액세스합니다. 다음 코드 조각은 GetCGOffset()을 사용하여 오프셋을 얻는 방법을 보여줍니다.

<code class="go">import (
    "context"
    "fmt"
    "strings"
    "github.com/Shopify/sarama"
)

func GetCGOffset(ctx context.Context, brokers, groupName, topic string) (int64, error) {
    config := sarama.NewConfig()
    config.Consumer.Offsets.AutoCommit.Enable = false

    client, err := sarama.NewConsumerGroup(strings.Split(brokers, ","), groupName, config)
    if err != nil {
        return 0, err
    }
    defer client.Close()

    info := gcInfo{}
    if err := client.Consume(ctx, []string{topic}, &info); err != nil {
        return 0, err
    }
    return info.offset, nil
}</code>

이 코드는 소비자 그룹을 생성하고 지정된 브로커에 연결합니다. 검색 프로세스 중에 오프셋이 업데이트되지 않도록 자동 커밋을 비활성화합니다. gcInfo 구조체는 소비자 그룹에서 처리 중인 현재 메시지 오프셋을 나타내는 초기 오프셋을 추적합니다.

이 메커니즘을 사용하면 개발자는 소비자 그룹의 오프셋을 쉽게 검사하고 관리할 수 있으므로 더 세부적인 제어가 가능합니다. 메시지 처리 및 추적

위 내용은 Sarama를 사용하여 Golang Kafka 10에서 소비자 그룹 오프셋을 검색하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!