Commitbf924ef

committed

Producer: update serialization data using protocol buffer

1 parentc7d1c67 commitbf924efCopy full SHA for bf924ef

File tree

-3

lines changed

-3

lines changed

Lines changed: 3 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -50,7 +50,7 @@ public static void main(String[] args) {`
`50`	`50`
`51`	`51`	`PropertiesproducerConfig =newProperties();`
`52`	`52`
`53`		`-producerConfig.put(ProducerConfig.CLIENT_ID_CONFIG,"consumer-group-1");`
	`53`	`+producerConfig.put(ProducerConfig.CLIENT_ID_CONFIG,"client-1");`
`54`	`54`	`producerConfig.put(ProducerConfig.RETRIES_CONFIG,0);`
`55`	`55`	`producerConfig.put(ProducerConfig.ACKS_CONFIG,"all");`
`56`	`56`
`@@ -62,13 +62,13 @@ public static void main(String[] args) {`
`62`	`62`	`//producerConfig.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, org.apache.kafka.common.serialization.StringSerializer.class.getName());`
`63`	`63`
`64`	`64`	`// send Protocol Buffer data`
`65`		`-//producerConfig.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, ProductProtobufSerializer.class.getName());`
	`65`	`+producerConfig.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,ProductProtobufSerializer.class.getName());`
`66`	`66`
`67`	`67`	`// send JSON data`
`68`	`68`	`//producerConfig.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, ProductJsonSerializer.class.getName());`
`69`	`69`
`70`	`70`	`// send AVRO data`
`71`		`-producerConfig.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,ProductAvroSerializer.class.getName());`
	`71`	`+//producerConfig.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, ProductAvroSerializer.class.getName());`
`72`	`72`
`73`	`73`	`Producerproducer =newKafkaProducer<String,String>(producerConfig);`
`74`	`74`

Comments

(0)