We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a1148b3 commit bebdd70Copy full SHA for bebdd70
AvroProducer-V1/AvroProducer.java
@@ -8,7 +8,8 @@ public static void main(String[] args) throws Exception{
8
String msg;
9
10
Properties props = new Properties();
11
- props.put("bootstrap.servers", "localhost:9092,localhost:9093"); props.put("key.serializer","org.apache.kafka.common.serialization.StringSerializer");
+ props.put("bootstrap.servers", "localhost:9092,localhost:9093");
12
+ props.put("key.serializer","org.apache.kafka.common.serialization.StringSerializer");
13
props.put("value.serializer", "io.confluent.kafka.serializers.KafkaAvroSerializer");
14
props.put("schema.registry.url", "http://localhost:8081");
15
0 commit comments