kafkacat -C -b localhostmessage-router-kafka:9092 -t HV_VES_PERF3GPP -D ""X security.protocol=SASL_PLAINTEXT -o -1X sasl.mechanisms=PLAIN -c 1 | protoc --decode_raw --proto_path=/root/hv-ves_sim/proto/
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"
root@hv-ves-sim:~/hv-ves_sim/proto#

kafkacat -C -b localhost:9092 -t HV_VES_PERF3GPP -D "" -o -1 -c 1 | protoc --decode_raw
1 {
  1: "sample-version"
        eventName2: "sample-event-nameperf3gpp"
  3: 1
    domain4: "perf3gpp"1
        eventId5: "perf3GPP22"
  6: "sample-event-name"
    eventType7: "sample-event-type"
  8: 1539263857
  9: 1539263857
  nfcNamingCode10: "sample-nfcnf-naming-code"
        nfNamingCode11: "sample-nfnfc-naming-code"
        nfVendorName12: "sample-nf-vendor-name"
        sourceId13: "sample-reporting-sourceentity-id"
        sourceName: "sample-xnf14: "sample-reporting-entity-name"
        reportingEntityId15: "sample-reportingsource-entity-id"
        reportingEntityName16: "sample-reporting-entityxnf-name"
  17: "UTC+02:00"
    priority18: 1
        startEpochMicrosec: 1539263857
        lastEpochMicrosec: 1539263857
        timeZoneOffset: "UTC+02:00"
        sequence"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
    vesEventListenerVersion5: "7.0.2perf3GPP22"
 } eventFields6: "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/ /\\\x/g'`"
\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\x10sample-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: {
        version: "sample-version"
        eventName: "sample-event-name"
        domain: "perf3gpp"
        eventId: "perf3GPP22"
        eventType: "sample-event-type"
        nfcNamingCode: "sample-nfc-naming-code"
        nfNamingCode: "sample-nf-naming-code"
        nfVendorName: "sample-nf-vendor-name"
        sourceId: "sample-source-id"
        sourceName: "sample-xnf-name"
        reportingEntityId: "sample-reporting-entity-id"
        reportingEntityName: "sample-reporting-entity-name"
        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\x94\x02\x0a\x0e\x73\x61\x6d\x70\x6c\x65\x2d\x73x76\x6f\x75x65\x72\x63x73\x65x69\x2dx6f\x69x6e\x64x12\x82x08\x01x70\x0fx65\x73x72\x61\x6dx66\x33\x67\x70\x70\x6cx18\x65x01\x2dx20\x78x01\x6ex2a\x66x0a\x2dx70\x6ex65\x61x72\x6dx66\x65x33\x8ax47\x01x50\x09x50\x55x32\x54x32\x43x32\x2bx11\x30x73\x32x61\x3ax6d\x30x70\x30x6c\x92x65\x01x2d\x05x65\x37x76\x2ex65\x30x6e\x2ex74\x32x2d\x12x6e\x0ex61\x74x6d\x65\x3a\x11\x73\x61\x74x6d\x20x70\x74x6c\x65\x73x2d\x74x65\x20\x74x76\x65\x73\x74

\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\x78x72\x6ex73\x66x69\x2dx6f\x6e\x12\x61x08\x6dx70\x65\x72\x8ax66\x01x33\x09x67\x55x70\x54x70\x43x18\x2bx01\x30x20\x32x01\x3ax2a\x30x0a\x30x70\x92x65\x01x72\x05x66\x37x33\x2ex47\x30x50\x2ex50\x32\x12x32\x0ex32\x74x11\x65x73\x73x61\x74x6d\x20x70\x74x6c\x65\x73x2d\x74x65\x20x76\x74\x65\x73\x74

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\x78x72\x6ex73\x66x69\x2dx6f\x6e\x61x12\x08\x6dx70\x65\x8ax72\x66\x33\x67\x70\x70\x18\x01\x20\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" | netcat k8s_node_ip 30222

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"

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
  name: dep-dcae-hv-ves-collector
  namespace: onap
  resourceVersion: "1452331"
  selfLink: /apis/extensions/v1beta1/namespaces/onap/deployments/dep-dcae-hv-ves-collector
  uid: 4f6c9488-c7e8-11e8-b920-026901117392
spec:
  progressDeadlineSeconds: 600
  replicas: 1
  revisionHistoryLimit: 10
  selector:
    matchLabels:
      app: dcae-hv-ves-collector
      cfydeployment: hv-ves
      cfynode: hv-ves
      cfynodeinstance: hv-ves_eipq6a
      k8sdeployment: dep-dcae-hv-ves-collector
  strategy:
    rollingUpdate:
      maxSurge: 1
      maxUnavailable: 1
    type: RollingUpdate
  template:
    metadata:
      creationTimestamp: null
      labels:
        app: dcae-hv-ves-collector
        cfydeployment: hv-ves
        cfynode: hv-ves
        cfynodeinstance: hv-ves_eipq6a
        k8sdeployment: dep-dcae-hv-ves-collector
    spec:
      containers:
      - env:
        - name: CONSUL_HOST
          value: consul-server.onap
        - name: VESHV_KEY_STORE_PASSWORD
          value: onaponap
        - name: VESHV_TRUST_STORE_PASSWORD
          value: onaponap
        - name: VESHV_KEY_STORE
          value: /etc/ves-hv/server.p12
        - name: VESHV_TRUST_STORE
          value: /etc/ves-hv/trust.p12
        - name: VESHV_CONFIG_URL
          value: http://consul-server.onap:8500/v1/kv/dcae-hv-ves-collector
        - name: VESHV_LISTEN_PORT
          value: "6061"
        - name: PODCONFIG_BINDING_IPSERVICE
          valueFrom:value: config-binding-service
        - name: POD_IP
 fieldRef:         valueFrom:
     apiVersion: v1      fieldRef:
              apiVersion: v1
              fieldPath: status.podIP
        image: dockernexus3.elasticonap.coorg:10001/beats/filebeat:5.5.0onap/org.onap.dcaegen2.collectors.hv-ves.hv-collector-main:1.0.0-SNAPSHOT
        imagePullPolicy: IfNotPresent
        name: filebeatdcae-hv-ves-collector
        resourcesports:
{}        - terminationMessagePathcontainerPort: /dev/termination-log 6061
          terminationMessagePolicyprotocol: FileTCP
        volumeMountsresources: {}
       - mountPathterminationMessagePath: /vardev/log/onap/dcae-hv-ves-collector
 termination-log
        terminationMessagePolicy: File
        namevolumeMounts:
component-log
        - mountPath: /usropt/shareapp/filebeatHvVesCollector/datalogs
          name: filebeatcomponent-datalog
        - mountPath: /usr/share/filebeat/filebeat.ymletc/ves-hv
          name: filebeat-confssldir
      - env:
  subPath: filebeat.yml      - dnsPolicyname: POD_IP
ClusterFirst       hostname: dcae-hv-ves-collector  valueFrom:
    imagePullSecrets:       - namefieldRef:
onap-docker-registry-key        restartPolicy: Always     apiVersion: v1
schedulerName: default-scheduler       securityContext: {}     fieldPath: status.podIP
terminationGracePeriodSeconds: 30       volumes:image: docker.elastic.co/beats/filebeat:5.5.0
      -  emptyDirimagePullPolicy: {}IfNotPresent
        name: component-logfilebeat
       - emptyDirresources: {}
        nameterminationMessagePath: filebeat-data/dev/termination-log
       - configMapterminationMessagePolicy: File
         defaultModevolumeMounts:
420        -   namemountPath: /var/log/onap/dcae-hv-filebeatves-configmapcollector
          name: filebeatcomponent-conflog
        - hostPathmountPath: /usr/share/filebeat/data
         path name: /dockerdata-nfs/sslfilebeat-data
        -  type: ""mountPath: /usr/share/filebeat/filebeat.yml
          name: ssldirfilebeat-conf
status:   availableReplicas: 1   conditions:   - lastTransitionTime: 2018-10-04T15:15:21ZsubPath: filebeat.yml
     lastUpdateTime: 2018-10-04T15:15:21Z
 dnsPolicy: ClusterFirst
   message: Deployment has minimum availability.hostname: dcae-hv-ves-collector
    reason  imagePullSecrets:
MinimumReplicasAvailable      status: "True"- name: onap-docker-registry-key
      typerestartPolicy: AvailableAlways
     - lastTransitionTimeschedulerName: 2018-10-04T15:15:21Zdefault-scheduler
      securityContext: {}
      terminationGracePeriodSeconds: 30
      lastUpdateTime: 2018-10-05T14:10:15Z
volumes:
      - emptyDir: {}
        name: component-log
   message: 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