Kafka přihlásí go služby

Question 1

Potřebuji kafka spotřebitele protokoly pro ladění. Jsem udělat následující:


    chanLogs := make(chan confluentkafka.LogEvent)
    go func() {
        for {
            logEv := <-chanLogs
            logger.Debug("KAFKA: " + logEv.String())
        }
    }()

    configMap["go.logs.channel.enable"] = true
    configMap["go.logs.channel"] = chanLogs

    consumer, err := confluentkafka.NewConsumer(&configMap)

    err := consumer.SubscribeTopics(Topics, nil)

A já nikdy dostat linku. Zkoušel jsem to s kafka chan (consumer.Logs()) se stejným výsledkem. Co dělám špatně?

UPD V úvodním příspěvku jsem neprávem nastavit parametr jméno. Ten správný je go.logs.channel.enable. Ale někdy to ještě nefunguje.

Question 2

Jak je popsáno v prohlášení o shodě, měli byste povolit tuto funkci:

go.logs.channel.enable (bool, false) - Forward log to Logs() channel.
go.logs.channel (chan kafka.LogEvent, nil) - Forward logs to application-provided channel instead of Logs(). Requires go.logs.channel.enable=true.

Takže změnit svůj kód, jako je:

    configMap["go.logs.channel"] = chanLogs
    configMap["go.logs.channel.enable"] = true

    consumer, err := confluentkafka.NewConsumer(&configMap)

Viz také v doc nebo ve vzorku na code repo zde

Question 3

Řešením bylo přidat

    configMap["debug"] = "all"

Našel jsem to tady

Matteo · Answer 1 · 2021-11-23T09:39:26

Jak je popsáno v prohlášení o shodě, měli byste povolit tuto funkci:

go.logs.channel.enable (bool, false) - Forward log to Logs() channel.
go.logs.channel (chan kafka.LogEvent, nil) - Forward logs to application-provided channel instead of Logs(). Requires go.logs.channel.enable=true.

Takže změnit svůj kód, jako je:

    configMap["go.logs.channel"] = chanLogs
    configMap["go.logs.channel.enable"] = true

    consumer, err := confluentkafka.NewConsumer(&configMap)

Viz také v doc nebo ve vzorku na code repo zde

Ano, jsem omylem napsal špatně název klíče. Ale to se právě taky. Řešení je parametr debug jako tady

Yura · Answer 2 · 2021-11-23T11:00:59

Řešením bylo přidat

    configMap["debug"] = "all"

Našel jsem to tady

Kafka přihlásí go služby

Otázka

V jiných jazycích

Tato stránka je v jiných jazycích

Populární v této kategorii

Oblíbené položky v této kategorii