Update apache-kafka-2/src/main/java/com/baeldung/kafka/message/ordering/MultiPartitionProducer.java
Co-authored-by: Liam Williams <liam.williams@zoho.com>
This commit is contained in:
		
							parent
							
								
									c4a467b60a
								
							
						
					
					
						commit
						51cf5cee5f
					
				| @ -9,7 +9,7 @@ import java.util.Properties; | ||||
| public class MultiPartitionProducer { | ||||
|     public static void main(String[] args) { | ||||
|         Properties props = new Properties(); | ||||
|         props.put("bootstrap.servers", "localhost:9092"); | ||||
|         props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092"); | ||||
|         props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringSerializer"); | ||||
|         props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, "com.baeldung.kafka.message.ordering.serialization.JacksonSerializer"); | ||||
| 
 | ||||
|  | ||||
		Loading…
	
	
			
			x
			
			
		
	
		Reference in New Issue
	
	Block a user