- Trailers are of header type in go.
- You can only read trailer after reading body
package main
import (
"io/ioutil"
"log"
export AWS_ACCESS_KEY_ID="XXXXX"
export AWS_SECRET_KEY="XXXXX"
zkServer
and kafka-server
listeners
& advertised.listerners
in server.properties
.kafka
in localgradle build
this repojava -jar build/libs/spring-kafka-0.0.1-SNAPSHOT.jar
http://localhost:8080/greetings?message=HelloManThisIsPublished
App Directory structure. Download from git repo.
So idea is pretty simple:
Modify the example pt. 6 in this way:
By default DialOption{grpc.WithInsecure()}
is used in example. And as docs mention you just need to replace WithInsecure
with transport creds.
//opts := []grpc.DialOption{grpc.WithInsecure()}
creds, _ := credentials.NewClientTLSFromFile("tls.crt", "")
opts := []grpc.DialOption{grpc.WithTransportCredentials(creds)}