We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 573df75 commit a8df49fCopy full SHA for a8df49f
kafka/kafka_test.go
@@ -36,7 +36,7 @@ func Test_Producer(t *testing.T) {
36
case err := <-AsyncProducer.Errors():
37
fmt.Println("AsyncProducer.Errors()", err.Error())
38
}
39
- }
+ , ,, }
40
}()
41
for {
42
Message := &sarama.ProducerMessage{
other/00_ff_test.go
@@ -0,0 +1,17 @@
1
+package main
2
+
3
+import (
4
+ "fmt"
5
+ "math/rand"
6
+ "testing"
7
+ "time"
8
+)
9
10
+//可以作为 hbase rowkey 前置补0
11
+func TestFF(t *testing.T) {
12
+ rand.Seed(time.Now().Unix())
13
+ for i := 1; i <= 256; i++ {
14
+ a := fmt.Sprintf("%02x", rand.Intn(256))
15
+ t.Log(a)
16
+ }
17
+}
0 commit comments