@@ -1,5 +1,10 @@
package kafka
type Consumer struct {
- client Client
+ client *Client
+ topic string
+}
+
+func NewConsumer(client *Client, topic string) *Consumer {
+ return &Consumer{client, topic}
}
type Producer struct {
+func NewProducer(client *Client, topic string) *Producer {
+ return &Producer{client, topic}