set and test: limit timeout to publish 15ms

Fix critical issue of kafkav2

w := &kafka.Writer{
		Addr:         kafka.TCP(k.addrs...),
		Balancer:     &kafka.RoundRobin{},
		BatchTimeout: 15 * time.Millisecond,
	}

v1.2.6 Fix issue sarama and update golang engine.

Update engine to golang 1.18
Fix issue kafka for consumer group.#1192
Update sarama to v1.37.2

update kafclient, fix issue connection when kafka broker restart

• fix issue connect of consumer when broker restart.
• add mechanicsm of publish async.
• update fix issue of sarama uptodate.

v1.1.1 Add new flow send single partition.

• Add interface struct IPubsub define all methods.
• Depredicate InitConsumer and OnScanMessages will be remove some version.
• Add PublishWithConfig to push message with multiple config. Now can add header, metadata.
  PublishWithConfig: help we can send message to a partition to process sync task.
• struct Topic add atrribute Partition to manual setup send message to a partition.

type Topic struct {
	Name       string
	AutoCommit bool
	Partition  *int32
}

• struct Message add attribute Header

type Message struct {
	Offset        int64  `json:"offset,omitempty"`
	Partition     int    `json:"partition,omitempty"`
	Topic         string `json:"topic,omitempty"`
	Body          []byte `json:"body,omitempty"`
	Timestamp     int64  `json:"timestamp,omitempty"`
	ConsumerGroup string `json:"consumer_group,omitempty"`
	Commit        func()
	// new property
	Headers map[string]string
}

• Add struct SenderConfig help add more information about sender.

// SenderConfig addion config when publish message
type SenderConfig struct {
	Metadata interface{}
	Headers  map[string]string
}

first release.

public lib.