«[56] Kafka Storage Error: ошибка диска при попытке доступа к файлу журнала на диске» - PullRequest
Новая
       12

«[56] Kafka Storage Error: ошибка диска при попытке доступа к файлу журнала на диске»

0 голосов
/ 14 апреля 2019

Я пытаюсь создать простую демонстрацию, используя Kafka с Go, но получаю эту ошибку: [56] Kafka Storage Error: disk error when trying to access log file on the disk

Я использую https://github.com/segmentio/kafka-go, и мой код ниже.Кто-нибудь может помочь решить эту ошибку? 

func main() {

    // to produce messages
    topic := "test-1"
    partition := 0
    fmt.Println("before connection")

    conn, _ := kafka.DialLeader(context.Background(), "tcp", "localhost:9092", topic, partition)
    conn.SetWriteDeadline(time.Now().Add(10*time.Second));

    conn.WriteMessages(
        kafka.Message{Value: []byte("one!")},
        kafka.Message{Value: []byte("two!")},
        kafka.Message{Value: []byte("three!")},
    )
    fmt.Println("afterWriteMessages")

    r := kafka.NewReader(kafka.ReaderConfig{
        Brokers:   []string{"localhost:9092"},
        Topic:     topic,
        Partition: 0,
        MinBytes:  10e3, // 10KB
        MaxBytes:  10e6, // 10MB
    })

    r.SetOffset(0)

    for {
        m, err := r.ReadMessage(context.Background())
        if err != nil {
            fmt.Println("err", err)
            break
        }
        fmt.Printf("message at offset %d: %s = %s\n", m.Offset, string(m.Key), string(m.Value))
    }

    r.Close()
    defer conn.Close()
}
...