@@ -101,27 +101,30 @@ type Record struct {
101
101
102
102
// Partition is the partition that a record is written to.
103
103
//
104
- // For producing, this is left unset. This will be set by the client as
105
- // appropriate. Alternatively, you can use the ManualPartitioner, which
106
- // makes it such that this field is always the field chosen when
107
- // partitioning (i.e., you partition manually ahead of time).
104
+ // For producing, this is left unset. This will be set by the client
105
+ // before the record is unbuffered. If you use the ManualPartitioner,
106
+ // the value of this field is always the partition chosen when
107
+ // producing (i.e., you partition manually ahead of time).
108
108
Partition int32
109
109
110
110
// Attrs specifies what attributes were on this record.
111
+ //
112
+ // For producing, this is left unset. This will be set by the client
113
+ // before the record is unbuffered.
111
114
Attrs RecordAttrs
112
115
113
116
// ProducerEpoch is the producer epoch of this message if it was
114
117
// produced with a producer ID. An epoch and ID of 0 means it was not.
115
118
//
116
119
// For producing, this is left unset. This will be set by the client
117
- // as appropriate .
120
+ // before the record is unbuffered .
118
121
ProducerEpoch int16
119
122
120
123
// ProducerEpoch is the producer ID of this message if it was produced
121
124
// with a producer ID. An epoch and ID of 0 means it was not.
122
125
//
123
126
// For producing, this is left unset. This will be set by the client
124
- // as appropriate .
127
+ // before the record is unbuffered .
125
128
ProducerID int64
126
129
127
130
// LeaderEpoch is the leader epoch of the broker at the time this
@@ -133,10 +136,10 @@ type Record struct {
133
136
134
137
// Offset is the offset that a record is written as.
135
138
//
136
- // For producing, this is left unset. This will be set by the client as
137
- // appropriate . If you are producing with no acks, this will just be
138
- // the offset used in the produce request and does not mirror the
139
- // offset actually stored within Kafka.
139
+ // For producing, this is left unset. This will be set by the client
140
+ // before the record is unbuffered . If you are producing with no acks,
141
+ // this will just be the offset used in the produce request and does
142
+ // not mirror the offset actually stored within Kafka.
140
143
Offset int64
141
144
142
145
// Context is an optional field that is used for enriching records.
0 commit comments