提交 4b85d81d 编写于 作者: T t_max

docs(TMQ): improve tmq document

上级 6a9efd2a
...@@ -87,6 +87,25 @@ void commitSync() throws SQLException; ...@@ -87,6 +87,25 @@ void commitSync() throws SQLException;
void close() throws SQLException; void close() throws SQLException;
``` ```
</TabItem>
<TabItem label="Go" value="Go">
```go
func NewConsumer(conf *Config) (*Consumer, error)
func (c *Consumer) Close() error
func (c *Consumer) Commit(ctx context.Context, message unsafe.Pointer) error
func (c *Consumer) FreeMessage(message unsafe.Pointer)
func (c *Consumer) Poll(timeout time.Duration) (*Result, error)
func (c *Consumer) Subscribe(topics []string) error
func (c *Consumer) Unsubscribe() error
```
</TabItem> </TabItem>
</Tabs> </Tabs>
...@@ -229,6 +248,56 @@ public class MetersDeserializer extends ReferenceDeserializer<Meters> { ...@@ -229,6 +248,56 @@ public class MetersDeserializer extends ReferenceDeserializer<Meters> {
} }
``` ```
</TabItem>
<TabItem label="Go" value="Go">
```go
config := tmq.NewConfig()
defer config.Destroy()
err = config.SetGroupID("test")
if err != nil {
panic(err)
}
err = config.SetAutoOffsetReset("earliest")
if err != nil {
panic(err)
}
err = config.SetConnectIP("127.0.0.1")
if err != nil {
panic(err)
}
err = config.SetConnectUser("root")
if err != nil {
panic(err)
}
err = config.SetConnectPass("taosdata")
if err != nil {
panic(err)
}
err = config.SetConnectPort("6030")
if err != nil {
panic(err)
}
err = config.SetMsgWithTableName(true)
if err != nil {
panic(err)
}
err = config.EnableHeartBeat()
if err != nil {
panic(err)
}
err = config.EnableAutoCommit(func(result *wrapper.TMQCommitCallbackResult) {
if result.ErrCode != 0 {
errStr := wrapper.TMQErr2Str(result.ErrCode)
err := errors.NewError(int(result.ErrCode), errStr)
panic(err)
}
})
if err != nil {
panic(err)
}
```
</TabItem> </TabItem>
</Tabs> </Tabs>
...@@ -260,6 +329,20 @@ topics.add("tmq_topic"); ...@@ -260,6 +329,20 @@ topics.add("tmq_topic");
consumer.subscribe(topics); consumer.subscribe(topics);
``` ```
</TabItem>
<TabItem value="Go" label="Go">
```go
consumer, err := tmq.NewConsumer(config)
if err != nil {
panic(err)
}
err = consumer.Subscribe([]string{"example_tmq_topic"})
if err != nil {
panic(err)
}
```
</TabItem> </TabItem>
</Tabs> </Tabs>
...@@ -293,6 +376,21 @@ while(running){ ...@@ -293,6 +376,21 @@ while(running){
} }
``` ```
</TabItem>
<TabItem value="Go" label="Go">
```go
for {
result, err := consumer.Poll(time.Second)
if err != nil {
panic(err)
}
fmt.Println(result)
consumer.Commit(context.Background(), result.Message)
consumer.FreeMessage(result.Message)
}
```
</TabItem> </TabItem>
</Tabs> </Tabs>
...@@ -322,6 +420,13 @@ consumer.unsubscribe(); ...@@ -322,6 +420,13 @@ consumer.unsubscribe();
consumer.close(); consumer.close();
``` ```
</TabItem>
<TabItem value="Go" label="Go">
```go
consumer.Close()
```
</TabItem> </TabItem>
</Tabs> </Tabs>
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册