- 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-serverlisteners & advertised.listerners in server.properties.kafka in localgradle build this repojava -jar build/libs/spring-kafka-0.0.1-SNAPSHOT.jarhttp://localhost:8080/greetings?message=HelloManThisIsPublishedApp 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)}