Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaProducer ¶
type KafkaProducer struct {
// contains filtered or unexported fields
}
func InitKafka ¶ added in v0.0.2
func InitKafka(servers []string) KafkaProducer
func (*KafkaProducer) SendMesssage ¶
func (t *KafkaProducer) SendMesssage(content []byte, topic string, keyType string) (int32, int64, error)
send message and return partition,offset
Source Files
Click to show internal directories.
Click to hide internal directories.