From f16ce6601380b22dfd159d4f9df5d16d72225b38 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=99=BD=E8=8C=B6=E6=B8=85=E6=AC=A2?= Date: Fri, 17 Jun 2022 20:32:31 +0800 Subject: [PATCH] =?UTF-8?q?=E8=87=AA=E5=AE=9A=E4=B9=89=E5=86=85=E5=AE=B9?= =?UTF-8?q?=E8=BF=81=E7=A7=BB=E5=88=B0define=E6=96=87=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- config.go | 21 --------------------- define.go | 29 +++++++++++++++++++++++++++++ 2 files changed, 29 insertions(+), 21 deletions(-) create mode 100644 define.go diff --git a/config.go b/config.go index 8610048..147149d 100644 --- a/config.go +++ b/config.go @@ -6,24 +6,3 @@ // // Date : 2021-09-21 3:48 下午 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 // 数据发送是否成功 -} diff --git a/define.go b/define.go new file mode 100644 index 0000000..21d3863 --- /dev/null +++ b/define.go @@ -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 // 数据发送是否成功 +}