|
@ -34,7 +34,6 @@ type TopicSubscriber struct { |
|
|
OnDataMessageFunc OnDataMessageFn |
|
|
OnDataMessageFunc OnDataMessageFn |
|
|
OnCompletionFunc OnCompletionFunc |
|
|
OnCompletionFunc OnCompletionFunc |
|
|
bootstrapBrokers []string |
|
|
bootstrapBrokers []string |
|
|
waitForMoreMessage bool |
|
|
|
|
|
activeProcessors map[topic.Partition]*ProcessorState |
|
|
activeProcessors map[topic.Partition]*ProcessorState |
|
|
activeProcessorsLock sync.Mutex |
|
|
activeProcessorsLock sync.Mutex |
|
|
PartitionOffsetChan chan KeyedOffset |
|
|
PartitionOffsetChan chan KeyedOffset |
|
@ -47,7 +46,6 @@ func NewTopicSubscriber(bootstrapBrokers []string, subscriber *SubscriberConfigu |
|
|
brokerPartitionAssignmentChan: make(chan *mq_pb.SubscriberToSubCoordinatorResponse, 1024), |
|
|
brokerPartitionAssignmentChan: make(chan *mq_pb.SubscriberToSubCoordinatorResponse, 1024), |
|
|
brokerPartitionAssignmentAckChan: make(chan *mq_pb.SubscriberToSubCoordinatorRequest, 1024), |
|
|
brokerPartitionAssignmentAckChan: make(chan *mq_pb.SubscriberToSubCoordinatorRequest, 1024), |
|
|
bootstrapBrokers: bootstrapBrokers, |
|
|
bootstrapBrokers: bootstrapBrokers, |
|
|
waitForMoreMessage: true, |
|
|
|
|
|
activeProcessors: make(map[topic.Partition]*ProcessorState), |
|
|
activeProcessors: make(map[topic.Partition]*ProcessorState), |
|
|
PartitionOffsetChan: partitionOffsetChan, |
|
|
PartitionOffsetChan: partitionOffsetChan, |
|
|
} |
|
|
} |
|
|