I hereby claim:
- I am douglarek on github.
- I am xinlingchao (https://keybase.io/xinlingchao) on keybase.
- I have a public key ASCADdYM3GJLi9fgF8sCGUPWNBQFrzdowCjou-24g7JwOwo
To claim this, I am signing this object:
I hereby claim:
To claim this, I am signing this object:
I hereby claim:
To claim this, I am signing this object:
$ CFLAGS="-I$(xcrun --show-sdk-path)/usr/include" pyenv install -v 3.7.0 |
# Set the retries to Integer.MAX_VALUE to ensure that transient failures | |
# will not result in data loss. | |
ksql.streams.producer.retries=2147483647 | |
# Set the batch expiry to Long.MAX_VALUE to ensure that queries will not | |
# terminate if the underlying Kafka cluster is unavailable for a period of | |
# time. | |
ksql.streams.producer.confluent.batch.expiry.ms=9223372036854775807 | |
# Allows more frequent retries of requests when there are failures, |
command-line:
$ h2load http://localhost:50051/helloworld.Greeter/SayHello \
-d grpc-upload \
-H 'te: trailers'
-H 'content-type: application/grpc'
-n1000000 -c100 -m100
Create grpc-upload file using following python script:
package main | |
import "encoding/json" | |
// jsonText comes from http://json.org/example.html | |
var jsonText = []byte(` | |
{ | |
... // 此处省略, 同上 | |
}`) |
package main | |
import "encoding/json" | |
// jsonText comes from http://json.org/example.html | |
var jsonText = []byte(` | |
{ | |
"glossary":{ | |
"title":"example glossary", | |
"GlossDiv":{ |
package main | |
import ( | |
"log" | |
"time" | |
"golang.org/x/sys/unix" | |
) | |
func main() { |
package main | |
import ( | |
"fmt" | |
"sync" | |
) | |
// Fetcher ... | |
type Fetcher interface { | |
// Fetch returns the body of URL and |