topic_partition.go 273 B

1234567891011121314
  1. package topic
  2. import "fmt"
  3. type TopicPartition struct {
  4. Namespace string
  5. Topic string
  6. RangeStart int32
  7. RangeStop int32
  8. }
  9. func (tp *TopicPartition) String() string {
  10. return fmt.Sprintf("%v.%v-%04d-%04d", tp.Namespace, tp.Topic, tp.RangeStart, tp.RangeStop)
  11. }