kafka

package

v0.0.0-...-a23e254 Latest Latest Go to latest Published: Aug 13, 2020 License: MIT Imports: 3 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/gaopengfei123123/go_study

Documentation ¶

Index ¶

Constants
type Kafka
- func (kf Kafka) Read(f func(jsonStr []byte))
- func (kf Kafka) Send(key string, value string)

Constants ¶

View Source

const (
	// KafkaTopic 指定的主题名
	KafkaTopic = "test-topic"
	// KafkaPatition 指定分区
	KafkaPatition = 0
	// KafkaHost kafka 链接地址
	KafkaHost = "localhost:9092"
)

kafka 的一些配置

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Kafka ¶

type Kafka struct{}

Kafka 的实体

func (Kafka) Read ¶

func (kf Kafka) Read(f func(jsonStr []byte))

Read 读取队列信息

func (Kafka) Send ¶

func (kf Kafka) Send(key string, value string)

Send 向队列发送消息

Source Files ¶

View all Source files

server.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL