diff --git a/define.go b/define.go index da708f5..21d3863 100644 --- a/define.go +++ b/define.go @@ -13,8 +13,8 @@ package kafka // // Date : 4:13 下午 2021/9/21 type ProducerData struct { - Data map[interface{}]interface{} // 发送的数据 - Key string // 分区key + Data interface{} // 发送的数据 + Key string // 分区key } // ProducerResult 数据发送后的结果