kafkacat -C -b message-router-kafka:9092 -t HV_VES_PERF3GPP -X security.protocol=SASL_PLAINTEXT -X sasl.mechanisms=PLAIN -X sasl.username=admin -X sasl.password=admin_secret -D "" -o -1 -c 1

?
sample-versionperf3gpp                                                      ???????{?sample-source-name?another-versiond
root@hv-ves-sim:~/hv-ves_sim# 

kafkacat -C -b localhost:9092 -t HV_VES_PERF3GPP -D "" -o -1 -c 1 | protoc --decode_raw
1 {
  1: "sample-version"
  2: "perf3gpp"
  3: 1
  4: 1
  5: "perf3GPP22"
  6: "sample-event-name"
  7: "sample-event-type"
  8: 1539263857
  9: 1539263857
  10: "sample-nf-naming-code"
  11: "sample-nfc-naming-code"
  12: "sample-nf-vendor-name"
  13: "sample-reporting-entity-id"
  14: "sample-reporting-entity-name"
  15: "sample-source-id"
  16: "sample-xnf-name"
  17: "UTC+02:00"
  18: "7.0.2"
}
2: "test test test"

kafkacat -C -b message-router-kafka:9092 -t HV_VES_PERF3GPP -X security.protocol=SASL_PLAINTEXT -X sasl.mechanisms=PLAIN -X sasl.username=admin -X sasl.password=admin_secret -D "" -o -1 -c 1 | protoc --decode_raw
1 {
  1: "sample-version"
  2: "perf3gpp"
  3: 1
  4: 1
  5: "perf3GPP22"
  6: "sample-event-name"
  7: "sample-event-type"
  8: 1539263857
  9: 1539263857
  10: "sample-nf-naming-code"
  11: "sample-nfc-naming-code"
  12: "sample-nf-vendor-name"
  13: "sample-reporting-entity-id"
  14: "sample-reporting-entity-name"
  15: "sample-source-id"
  16: "sample-xnf-name"
  17: "UTC+02:00"
  18: "7.0.2"
}
2: "test test test"

cd ~/hv-ves_sim/proto ; cat hvves_event 
commonEventHeader: {
        eventIdversion: "sample-event-idversion"
        eventName: "sample-event-name"
        eventTypedomain: "sample-event-typeperf3gpp"
        startEpochMicroseceventId: 120034455"perf3GPP22"
        lastEpochMicroseceventType: 120034455"sample-event-type"
        nfNamingCodenfcNamingCode: "sample-nfnfc-naming-code"
        nfcNamingCodenfNamingCode: "sample-nfcnf-naming-code"
        reportingEntityIdnfVendorName: "sample-reportingnf-entityvendor-idname"
        reportingEntityNamesourceId: "sample-reportingsource-entity-nameid"
        sourceIdsourceName: "sample-sourcexnf-idname"
        sourceNamereportingEntityId: "sample-reporting-sourceentity-nameid"
        vesEventListenerVersionreportingEntityName: "another-versionsample-reporting-entity-name"
    } eventFields: "test test test"
root@hv-ves-sim:~/hv-ves_sim/proto# echo -n "\x`cat hvves_event | protoc -I=/root/hv-ves_sim/proto/ VesEvent.proto --encode=VesEvent | xxd -p -c 1000 | grep -o .. | xargs echo -n | sed 's/ priority: 1
        startEpochMicrosec: 1539263857
        lastEpochMicrosec: 1539263857
        timeZoneOffset: "UTC+02:00"
        sequence: 1
        vesEventListenerVersion: "7.0.2"
}
eventFields: "test test test"

cd ~/hv-ves_sim/proto ; echo -n "\x`cat hvves_event | protoc -I=/root/hv-ves_sim/proto VesEvent.proto --encode=VesEvent | xxd -p -c 1000 | grep -o .. | xargs echo -n | sed 's/ /\\\x/g'`"
\x0a\xffx94\x01x02\x0a\x0e\x73\x61\x6d\x70\x6c\x65\x2d\x76\x65\x72\x73\x69\x6f\x6e\x12\x08\x70\x06x65\x48x72\x56x66\x4dx33\x45x67\x41x70\x53x70\x18\x01\x20\x01\x2a\x0fx0a\x73x70\x61x65\x6dx72\x70x66\x6cx33\x65x47\x2dx50\x65x50\x76x32\x65\x6e\x74\x2d\x69\x64\x32\x32\x11\x73\x61\x6d\x70\x6c\x65\x2d\x65\x76\x65\x6e\x74\x2d\x6e\x61\x6d\x65\x3a\x11\x73\x61\x6d\x70\x6c\x65\x2d\x65\x76\x65\x6e\x74\x2d\x74\x79\x70\x65\x40\xf1\x97x9a\xa9xfd\x9exdd\x39x05\x48\xf1\x97x9a\xa9xfd\x9exdd\x39x05\x52\x15\x73\x61\x6d\x70\x6c\x65\x2d\x6e\x66\x2d\x6e\x61\x6d\x69\x6e\x67\x2d\x63\x6f\x64\x65\x5a\x16\x73\x61\x6d\x70\x6c\x65\x2d\x6e\x66\x63\x2d\x6e\x61\x6d\x69\x6e\x67\x2d\x63\x6f\x64\x65\x62\x15\x73\x61\x6d\x70\x6c\x65\x2d\x6e\x66\x2d\x76\x65\x6e\x64\x6f\x72\x2d\x6e\x61\x6d\x65\x6a\x1a\x73\x61\x6d\x70\x6c\x65\x2d\x72\x65\x70\x6f\x72\x74\x69\x6e\x67\x2d\x65\x6e\x74\x69\x74\x79\x2d\x69\x64\x72\x1c\x73\x61\x6d\x70\x6c\x65\x2d\x72\x65\x70\x6f\x72\x74\x69\x6e\x67\x2d\x65\x6e\x74\x69\x74\x79\x2d\x6e\x61\x6d\x65\x7a\x10\x73\x61\x6d\x70\x6c\x65\x2d\x73\x6f\x75\x72\x63\x65\x2d\x69\x64\x82\x01\x12x0f\x73\x61\x6d\x70\x6c\x65\x2d\x73x78\x6f\x75\x72\x63\x65\x6e\x66\x2d\x6e\x61\x6d\x65\x92x8a\x01\x09\x0fx55\x54\x61x43\x6ex2b\x6fx30\x74x32\x68x3a\x65x30\x72x30\x2dx92\x76x01\x65x05\x72x37\x73x2e\x69x30\x6fx2e\x6ex32\x12\x0e\x74\x65\x73\x74\x20\x74\x65\x73\x74\x20\x74\x65\x73\x74

kafkacat -C -b message-router-kafka:9092 -t HV_VES_PERF3GPP -X security.protocol=SASL_PLAINTEXT -X sasl.mechanisms=PLAIN -X sasl.username=admin -X sasl.password=admin_secret -D "" -o -1 -c 1 | protoc --decode_raw
1 {
  1: "sample-version"
  2: "perf3gpp"
  3: 1
  4: 1
  5: "perf3GPP22"
  6: "sample-event-name"
  7: "sample-event-type"
  8: 1539263857
  9: 1539263857
  10: "sample-nf-naming-code"
  11: "sample-nfc-naming-code"
  12: "sample-nf-vendor-name"
  13: "sample-reporting-entity-id"
  14: "sample-reporting-entity-name"
  15: "sample-source-id"
  16: "sample-xnf-name"
  17: "UTC+02:00"
  18: "7.0.2"
}
2: "test test test"

apiVersion: extensions/v1beta1
kind: Deployment
metadata:
  annotations:
    deployment.kubernetes.io/revision: "4"
  creationTimestamp: 2018-10-04T15:15:21Z
  generation: 4
  labels:
    app: dcae-hv-ves-collector
    cfydeployment: hv-ves
    cfynode: hv-ves
   
    cfynodeinstance: hv-ves_eipq6a
  
     k8sdeployment: dep-dcae-hv-ves-collector
    specname: dep-dcae-hv-ves-collector
     containersnamespace: onap
  resourceVersion: "1452331"
 - envselfLink: /apis/extensions/v1beta1/namespaces/onap/deployments/dep-dcae-hv-ves-collector
       - name: CONSUL_HOST
          value: consul-server.onap
  uid: 4f6c9488-c7e8-11e8-b920-026901117392
spec:
  progressDeadlineSeconds: 600
  replicas: 1
  revisionHistoryLimit: 10
  selector:
    matchLabels:
     - name: VESHV_KEY_STORE_PASSWORDapp: dcae-hv-ves-collector
      cfydeployment: hv-ves
   value: onaponap  cfynode: hv-ves
     - namecfynodeinstance: VESHV_TRUST_STORE_PASSWORDhv-ves_eipq6a
      k8sdeployment: dep-dcae-hv-ves-collector
  valuestrategy:
 onaponap   rollingUpdate:
     - namemaxSurge: VESHV_KEY_STORE1
          value: /etc/ves-hv/server.p12maxUnavailable: 1
    type: RollingUpdate
  - nametemplate:
VESHV_TRUST_STORE    metadata:
      valuecreationTimestamp: /etc/ves-hv/trust.p12null
        - name: VESHV_CONFIG_URLlabels:
          valueapp: http://consul-server.onap:8500/v1/kv/dcae-hv-ves-collector
        - namecfydeployment: VESHV_LISTEN_PORThv-ves
        cfynode: hv-ves
value: "6061"       cfynodeinstance:  - name: CONFIG_BINDING_SERVICEhv-ves_eipq6a
          valuek8sdeployment: config-binding-servicedep-dcae-hv-ves-collector
    spec:
     - namecontainers:
 POD_IP     - env:
    valueFrom:    - name: CONSUL_HOST
      fieldRef:    value: consul-server.onap
        - apiVersionname: v1VESHV_KEY_STORE_PASSWORD
          value: onaponap
  fieldPath: status.podIP     - name: VESHV_TRUST_STORE_PASSWORD
 image: nexus3.onap.org:10001/onap/org.onap.dcaegen2.collectors.hv-ves.hv-collector-main:1.0.0-SNAPSHOT        value: imagePullPolicy:onaponap
IfNotPresent        - name: dcae-hv-ves-collector VESHV_KEY_STORE
          ports:value: /etc/ves-hv/server.p12
        - containerPortname: 6061VESHV_TRUST_STORE
          protocol: TCPvalue: /etc/ves-hv/trust.p12
        - resourcesname: {}VESHV_CONFIG_URL
          terminationMessagePathvalue: /dev/termination-loghttp://consul-server.onap:8500/v1/kv/dcae-hv-ves-collector
        - terminationMessagePolicy: Filename: VESHV_LISTEN_PORT
          volumeMountsvalue: "6061"
        - mountPathname: /opt/app/HvVesCollector/logsCONFIG_BINDING_SERVICE
          namevalue: componentconfig-binding-logservice
        - mountPathname: /etc/ves-hvPOD_IP
          namevalueFrom:
ssldir       - env:    fieldRef:
    - name: POD_IP        apiVersion: v1
 valueFrom:             fieldReffieldPath: status.podIP
        image: nexus3.onap.org:10001/onap/org.onap.dcaegen2.collectors.hv-ves.hv-collector-main:1.0.0-SNAPSHOT
   apiVersion: v1    imagePullPolicy: IfNotPresent
         fieldPathname: status.podIPdcae-hv-ves-collector
        imageports:
docker.elastic.co/beats/filebeat:5.5.0        - imagePullPolicycontainerPort: 6061
 IfNotPresent         nameprotocol: filebeatTCP
        resources: {}
        terminationMessagePath: /dev/termination-log
        terminationMessagePolicy: File
        volumeMounts:
        - mountPath: /varopt/logapp/onap/dcae-hv-ves-collectorHvVesCollector/logs
          name: component-log
        - mountPath: /usr/share/filebeat/dataetc/ves-hv
          name: filebeat-datassldir
        - mountPath: /usr/share/filebeat/filebeat.ymlenv:
        -  name: filebeat-confPOD_IP
          subPath: filebeat.yml
 valueFrom:
    dnsPolicy: ClusterFirst       hostname: dcae-hv-ves-collectorfieldRef:
      imagePullSecrets:       - nameapiVersion: onap-docker-registry-keyv1
      restartPolicy: Always       schedulerNamefieldPath: default-scheduler status.podIP
        securityContextimage: {}docker.elastic.co/beats/filebeat:5.5.0
        terminationGracePeriodSecondsimagePullPolicy: IfNotPresent
30        volumesname: filebeat
      -  emptyDirresources: {}
        nameterminationMessagePath: component/dev/termination-log
       - emptyDirterminationMessagePolicy: {}File
        namevolumeMounts:
filebeat-data        - configMap:mountPath: /var/log/onap/dcae-hv-ves-collector
          defaultModename: 420component-log
        -  namemountPath: dcae-filebeat-configmap/usr/share/filebeat/data
          name: filebeat-confdata
        - hostPathmountPath: /usr/share/filebeat/filebeat.yml
         path name: /dockerdata-nfs/sslfilebeat-conf
          typesubPath: ""filebeat.yml
      dnsPolicy: ClusterFirst
 name: ssldir status:   availableReplicashostname: 1dcae-hv-ves-collector
  conditions:   - lastTransitionTimeimagePullSecrets: 2018-10-04T15:15:21Z
      - lastUpdateTimename: 2018onap-docker-10-04T15:15:21Zregistry-key
      messagerestartPolicy: DeploymentAlways
has minimum availability.     reason: MinimumReplicasAvailableschedulerName: default-scheduler
     status: "True" securityContext: {}
      terminationGracePeriodSeconds: 30
      typevolumes:
Available      - lastTransitionTime emptyDir: {}
        name: 2018-10-04T15:15:21Zcomponent-log
      - emptyDir: {}
        lastUpdateTimename: 2018-10-05T14:10:15Zfilebeat-data
      - configMap:
          messagedefaultMode: ReplicaSet "dep-dcae-hv-ves-collector-7986d777dc" has successfully progressed.
    reason: NewReplicaSetAvailable
    status: "True"
    type: Progressing
  observedGeneration: 4
  readyReplicas: 1
  replicas: 1
  updatedReplicas: 1

openssl genrsa -out ca.key 2048
openssl req -new -x509 -days 36500 -key ca.key -out ca.pem -subj /CN=dcae-hv-ves-ca

openssl genrsa -out server.key 2048
openssl req -new -key server.key -out server.csr -subj /CN=dcae-hv-ves-collector

openssl genrsa -out client.key 2048
openssl req -new -key client.key -out client.csr -subj /CN=dcae-hv-ves-client

openssl x509 -req -days 36500 -in server.csr -CA ca.pem -CAkey ca.key -out server.pem -set_serial 00
openssl x509 -req -days 36500 -in client.csr -CA ca.pem -CAkey ca.key -out client.pem -set_serial 00

openssl pkcs12 -export -out ca.p12 -inkey ca.key -in ca.pem -passout pass:
openssl pkcs12 -export -out server.p12 -inkey server.key -in server.pem -passout pass:

cat client.key client.pem > client-all.pem

echo -ne "\xaa\x01\x00\x00\x00\x00\x00\x01\x00\x00\x01\x27\x0a\x94\x02\x0a\x0e\x73\x61\x6d\x70\x6c\x65\x2d\x76\x65\x72\x73\x69\x6f\x6e\x12\x08\x70\x65\x72\x66\x33\x67\x70\x70\x18\x01\x20\x01\x2a\x0a\x70\x65\x72\x66\x33\x47\x50\x50\x32\x32\x32\x11\x73\x61\x6d\x70\x6c\x65\x2d\x65\x76\x65\x6e\x74\x2d\x6e\x61\x6d\x65\x3a\x11\x73\x61\x6d\x70\x6c\x65\x2d\x65\x76\x65\x6e\x74\x2d\x74\x79\x70\x65\x40\xf1\x9a\xfd\xdd\x05\x48\xf1\x9a\xfd\xdd\x05\x52\x15\x73\x61\x6d\x70\x6c\x65\x2d\x6e\x66\x2d\x6e\x61\x6d\x69\x6e\x67\x2d\x63\x6f\x64\x65\x5a\x16\x73\x61\x6d\x70\x6c\x65\x2d\x6e\x66\x63\x2d\x6e\x61\x6d\x69\x6e\x67\x2d\x63\x6f\x64\x65\x62\x15\x73\x61\x6d\x70\x6c\x65\x2d\x6e\x66\x2d\x76\x65\x6e\x64\x6f\x72\x2d\x6e\x61\x6d\x65\x6a\x1a\x73\x61\x6d\x70\x6c\x65\x2d\x72\x65\x70\x6f\x72\x74\x69\x6e\x67\x2d\x65\x6e\x74\x69\x74\x79\x2d\x69\x64\x72\x1c\x73\x61\x6d\x70\x6c\x65\x2d\x72\x65\x70\x6f\x72\x74\x69\x6e\x67\x2d\x65\x6e\x74\x69\x74\x79\x2d\x6e\x61\x6d\x65\x7a\x10\x73\x61\x6d\x70\x6c\x65\x2d\x73\x6f\x75\x72\x63\x65\x2d\x69\x64\x82\x01\x0f\x73\x61\x6d\x70\x6c\x65\x2d\x78\x6e\x66\x2d\x6e\x61\x6d\x65\x8a\x01\x09\x55\x54\x43\x2b\x30\x32\x3a\x30\x30\x92\x01\x05\x37\x2e\x30\x2e\x32\x12\x0e\x74\x65\x73\x74\x20\x74\x65\x73\x74\x20\x74\x65\x73\x74" | openssl s_client -connect dcae-hv-ves-collector:30222 -CAfile ca.pem -msg -state -cert client-all.pem