小编Pem*_*anZ的帖子

我正在使用 Kafka 0.10.1.1 并编写一个测试生产者，但在producer.send onCompletion回调中出现错误：

        producer.send(record, new Callback() {
        @Override
        public void onCompletion(RecordMetadata metadata, Exception e) {
            if (e != null){
                System.out.println(e.getMessage());
            }
        }
    });

带有配置的生产者： timeout.ms=30000, linger.ms=5, batch.size=1000

收到以下错误消息：

自上次追加以来，由于 30004 毫秒，testtopic-2 的 1 条记录已过期

但是这个错误信息只是有时出现。制片人有时可以工作得很好。

我在下面定义了一个struct,但总是得到构建错误:"undefined:bytes in bytes.Buffer"

type test struct {
    id       int64
    Content    []byte
    Buffer     *bytes.Buffer
}