zhangdeman/kafka
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

自定义内容迁移到define文件

Browse Source
This commit is contained in:
白茶清欢 2022-06-17 20:32:31 +08:00
parent ac98d07993
commit f16ce66013
2 changed files with 29 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
config.go
View File

@ -6,24 +6,3 @@
// //
// Date : 2021-09-21 3:48 下午 // Date : 2021-09-21 3:48 下午
package kafka package kafka
// ProducerData 生产数据
//
// Author : go_developer@163.com<白茶清欢>
//
// Date : 4:13 下午 2021/9/21
type ProducerData struct {
Data interface{} // 发送的数据
Key string // 分区key
}
// ProducerResult 数据发送后的结果
//
// Author : go_developer@163.com<白茶清欢>
//
// Date : 4:15 下午 2021/9/21
type ProducerResult struct {
Partition int32 // 数据落入的分区
Offset int64 // 数据对应的Offset
Err error // 数据发送是否成功
}

29
define.go Normal file
View File

@ -0,0 +1,29 @@
// Package kafka ...
//
// Description : kafka ...
//
// Author : go_developer@163.com<白茶清欢>
//
// Date : 2022-06-17 20:31
package kafka
// ProducerData 生产数据
//
// Author : go_developer@163.com<白茶清欢>
//
// Date : 4:13 下午 2021/9/21
type ProducerData struct {
Data interface{} // 发送的数据
Key string // 分区key
}
// ProducerResult 数据发送后的结果
//
// Author : go_developer@163.com<白茶清欢>
//
// Date : 4:15 下午 2021/9/21
type ProducerResult struct {
Partition int32 // 数据落入的分区
Offset int64 // 数据对应的Offset
Err error // 数据发送是否成功
}