ag-ramachandran

---
    version: '3'
    
    services:
      zookeeper:
        image: confluentinc/cp-zookeeper:6.2.5
        hostname: zookeeper
        container_name: zookeeper
        ports:
          - "2181:2181"

ag-ramachandran

package kafka;

import com.github.javafaker.Faker;
import com.google.protobuf.ByteString;
import com.microsoft.kusto.test.protobuf.SensorReadingWithDeviceDataImpl;
import io.confluent.kafka.serializers.protobuf.KafkaProtobufSerializer;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.common.serialization.StringSerializer;

ag-ramachandran

<?xml version="1.0" encoding="utf-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <groupId>com.microsoft.adx</groupId>
  <artifactId>kafka-send-proto</artifactId>
  <packaging>jar</packaging>
  <version>0.1.0</version>
  <build>
    <plugins>
      <plugin>

ag-ramachandran

---
    version: '3'
    
    services:
      zookeeper:
        image: confluentinc/cp-zookeeper:6.2.5
        hostname: zookeeper
        container_name: zookeeper
        ports:
          - "2181:2181"