File tree Expand file tree Collapse file tree 2 files changed +2
-2
lines changed
src/main/java/com/programming/videoService/config Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -19,7 +19,7 @@ public class KafkaConsumerConfig {
1919 @ Bean
2020 public Map <String , Object > consumerConfigs () {
2121 Map <String , Object > props = new HashMap <>();
22- props .put (ConsumerConfig .BOOTSTRAP_SERVERS_CONFIG , "192.168.120.131:30392 " );
22+ props .put (ConsumerConfig .BOOTSTRAP_SERVERS_CONFIG , "192.168.2.240:9092 " );
2323 props .put (ConsumerConfig .GROUP_ID_CONFIG , "video-genres-group" ); // Tên group ID
2424 props .put (ConsumerConfig .KEY_DESERIALIZER_CLASS_CONFIG , StringDeserializer .class );
2525 props .put (ConsumerConfig .VALUE_DESERIALIZER_CLASS_CONFIG , StringDeserializer .class );
Original file line number Diff line number Diff line change @@ -16,7 +16,7 @@ public class KafkaProducerConfig {
1616 @ Bean
1717 public Map <String , Object > producerConfigs () {
1818 Map <String , Object > props = new HashMap <>();
19- props .put (ProducerConfig .BOOTSTRAP_SERVERS_CONFIG , "192.168.120.131:30392 " );
19+ props .put (ProducerConfig .BOOTSTRAP_SERVERS_CONFIG , "192.168.2.240:9092 " );
2020 props .put (ProducerConfig .KEY_SERIALIZER_CLASS_CONFIG , StringSerializer .class );
2121 props .put (ProducerConfig .VALUE_SERIALIZER_CLASS_CONFIG , StringSerializer .class );
2222 return props ;
You can’t perform that action at this time.
0 commit comments