13 lines
167 B
Go
13 lines
167 B
Go
package model
|
|
|
|
import "time"
|
|
|
|
type InputMessage struct {
|
|
Topic string
|
|
Partition int
|
|
Key []byte
|
|
Value []byte
|
|
Offset int64
|
|
Timestamp *time.Time
|
|
}
|